Add Sink.watchTermination operator

Open

#2,377 opened on Oct 25, 2025 0 comments 0 reactions 0 assignees View on GitHub

t:stream

Description

Motivation:
refs: https://github.com/akka/akka-core/issues/22546

I encountered this when implementing the `doOnCancel`, but it seems `doOnCancel` can handle this.

I got a quick prototype

This issue has not been assessed yet.