Method Process
Process<TElement>(IObservable<TElement>, Func<TElement, TSource>)
Writes all elements of an observable sequence to a file.
protected IObservable<TElement> Process<TElement>(IObservable<TElement> source, Func<TElement, TSource> selector)
Parameters
sourceIObservable<TElement>The sequence of elements to write to the file.
selectorFunc<TElement, TSource>The transform function used to convert each element of the sequence into the type of inputs accepted by the file writer.
Returns
- IObservable<TElement>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the elements to a file.
Type Parameters
TElementThe type of the elements in the source sequence.
Exceptions
Process<TElement>(IObservable<TElement>, Func<TElement, TSource>, string)
Writes all elements of an observable sequence to the specified file.
protected IObservable<TElement> Process<TElement>(IObservable<TElement> source, Func<TElement, TSource> selector, string fileName)
Parameters
sourceIObservable<TElement>The sequence of elements to write to the file.
selectorFunc<TElement, TSource>The transform function used to convert each element of the sequence into the type of inputs accepted by the file writer.
fileNamestringThe name of the file on which to write the elements.
Returns
- IObservable<TElement>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the elements to a file.
Type Parameters
TElementThe type of the elements in the source sequence.
Exceptions
Process(IObservable<TSource>)
Writes all elements of an observable sequence to the specified file.
public virtual IObservable<TSource> Process(IObservable<TSource> source)
Parameters
sourceIObservable<TSource>The sequence of elements to write to the file.
Returns
- IObservable<TSource>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the elements to a file.