Sink.source

A Sink that materializes this Sink itself as a Source, the returning Source can only have one subscriber.

Sink operators

Signature

Sink.sourceSink.source Sink.sourceSink.source

Description

A Sink that materialize this Sink itself as a Source, the returning Source can only have one subscriber.

Use BroadcastHub.sink if you need a Source that allows multiple subscribers.

Reactive Streams semantics

cancels When the materialized Source is cancelled or timeout with subscription.

backpressures When the materialized Source backpressures or not ready to receive elements.

2.0.0-M0+208-8bcc6969*