fromSubscriber

Integration with Reactive Streams, wraps a org.reactivestreams.Subscriber as a sink.

Sink stages

Signature

def fromSubscriber[T](subscriber: Subscriber[T]): Sink[T, NotUsed]
Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.