asPublisher

Integration with Reactive Streams, materializes into a org.reactivestreams.Publisher.

Sink stages

Signature

def asPublisher[T](fanout: Boolean): Sink[T, Publisher[T]]
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.