Sink.fromSubscriber

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

Sink operators

Signature

Sink.fromSubscriberSink.fromSubscriber

Description

In Java 9, the Reactive Stream API was included in the JDK, and Subscriber is available through Flow.Subscriber. Since those APIs are identical but exist at different package namespaces and does not depend on the Reactive Streams package a separate API for those is available through org.apache.pekko.stream.scaladsl.JavaFlowSupport.Sink#fromSubscriberorg.apache.pekko.stream.javadsl.JavaFlowSupport.Sink#fromSubscriber.