watchTermination

Materializes to a Future CompletionStage that will be completed with Done or failed depending whether the upstream of the stage has been completed or failed.

Watching status stages

Signature

def watchTermination[Mat2]()(matF: (Mat, Future[Done]) ⇒ Mat2): ReprMat[Out, Mat2]

Description

Materializes to a Future CompletionStage that will be completed with Done or failed depending whether the upstream of the stage has been completed or failed. The stage otherwise passes through elements unchanged.

emits when input has an element available

backpressures when output backpressures

completes when upstream completes

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.