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.