# Sink.cancelled

Immediately cancel the stream

@ref[Sink operators](../index.md#sink-operators)

## Signature

@apidoc[Sink.cancelled](Sink$) { scala="#cancelled[T]:akka.stream.scaladsl.Sink[T,akka.NotUsed]" java="#cancelled()" }


## Description

Immediately cancel the stream

## Reactive Streams semantics

@@@div { .callout }

**cancels** immediately

@@@


