Class StreamSink<TSource, TWriter>
Provides a base class for sinks that write the elements from the input sequence into a named stream (e.g. a named pipe).
public abstract class StreamSink<TSource, TWriter> : StreamSink where TWriter : class, IDisposable
Type Parameters
TSource
The type of the elements in the source sequence.
TWriter
The type of stream writer that should be used to write the elements.
- Inheritance
-
StreamSink<TSource, TWriter>
- Derived
- Inherited Members
Methods
- CreateWriter(Stream)
When overridden in a derived class, creates the object that will be responsible for writing the input elements to the specified Stream.
- Process(IObservable<TSource>)
Writes all elements of an observable sequence to the specified stream.
- Process<TElement>(IObservable<TElement>, Func<TElement, TSource>)
Writes all elements of an observable sequence to a stream.
- Process<TElement>(IObservable<TElement>, Func<TElement, TSource>, string)
Writes all elements of an observable sequence into the specified stream.
- Write(TWriter, TSource)
When overridden in a derived class, writes a new element using the specified writer.