Sink.futureSink

Streams the elements to the given future sink once it successfully completes.

Sink operators

Signature

def futureSink[T, M](future: Future[Sink[T, M]]): Sink[T, Future[M]]

Description

Streams the elements through the given future flow once it successfully completes. If the future fails the stream is failed.

Reactive Streams semantics

cancels if the future fails or if the created sink cancels

backpressures when initialized and when created sink backpressures

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.