asSubscriber

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

Source stages

Signature

def asSubscriber[T]: Source[T, Subscriber[T]]

Description

@@@div { .callout }

@@@

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.