StreamSinkExtensions<T> extension

Extensions on StreamSink to make stream transformations more fluent.

on

Methods

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