fromPublisher

Integration with Reactive Streams, subscribes to a org.reactivestreams.Publisher.

Source stages

Signature

def fromPublisher[T](publisher: Publisher[T]): Source[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.