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
source
IObservable<TElement>The sequence of elements to write to the file.
selector
Func<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
source
sequence but where there is an additional side effect of writing the elements to a file.
Type Parameters
TElement
The 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
source
IObservable<TElement>The sequence of elements to write to the file.
selector
Func<TElement, TSource>The transform function used to convert each element of the sequence into the type of inputs accepted by the file writer.
fileName
stringThe name of the file on which to write the elements.
Returns
- IObservable<TElement>
An observable sequence that is identical to the
source
sequence but where there is an additional side effect of writing the elements to a file.
Type Parameters
TElement
The 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
source
IObservable<TSource>The sequence of elements to write to the file.
Returns
- IObservable<TSource>
An observable sequence that is identical to the
source
sequence but where there is an additional side effect of writing the elements to a file.