cancelled Immediately cancel the stream Sink operators Signature def cancelled[T]: Sink[T, NotUsed] Description Immediately cancel the stream cancels immediately