Method Process

Writes all elements of an observable sequence to a stream.

protected IObservable<TElement> Process<TElement>(IObservable<TElement> source, Func<TElement, TSource> selector)

source IObservable<TElement>: The sequence of elements to write.
selector Func<TElement, TSource>: The transform function used to convert each element of the sequence into the type of inputs accepted by the stream writer.

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 stream.

Writes all elements of an observable sequence into the specified stream.

protected IObservable<TElement> Process<TElement>(IObservable<TElement> source, Func<TElement, TSource> selector, string path)

source IObservable<TElement>: The sequence of elements to write.
selector Func<TElement, TSource>: The transform function used to convert each element of the sequence into the type of inputs accepted by the stream writer.
path string: The identifier of the stream on which to write the elements.

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 the named stream.

Writes all elements of an observable sequence to the specified stream.

public virtual IObservable<TSource> Process(IObservable<TSource> source)

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 stream.