Sink.onComplete

Invoke a callback when the stream has completed or failed.

Sink operators

Signature

def onComplete[T](callback: Try[Done] ⇒ Unit): Sink[T, NotUsed]

Description

Invoke a callback when the stream has completed or failed.

cancels never

backpressures never

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.