StreamSinkExtensions<T> extension

Extensions on StreamSink to make stream transformations more fluent.

on

Methods

rejectErrors() → StreamSink<T>

Available on StreamSink<T>, provided by the StreamSinkExtensions extension

Returns a StreamSink that forwards to this but rejects errors.
transform<S>(StreamSinkTransformer<S, T> transformer) → StreamSink<S>

Available on StreamSink<T>, provided by the StreamSinkExtensions extension

Transforms a StreamSink using transformer.