feat: add Sink.watchTermination operator - #3409

Draft

He-Pin wants to merge 6 commits into

mainfrom

feat/sink-watch-termination

Commits on Aug 4, 2026

feat: add Sink.watchTermination operator
He-Pin
committed
9f13fb3

Commits on Aug 14, 2026

refactor: fuse InHandler into WatchedSinkLogic and use OptionVal
He-Pin
committed
df56648

Commits on Aug 15, 2026

style: scalafmt formatting for WatchedSink
He-Pin
committed
269a2d3
fix: delegate dynamically to inner handler in WatchedSinkLogic
He-Pin
committed
4e056af
feat: support arbitrary composite sinks in Sink.watchTermination
He-Pin
committed
5f5f9dd

Commits on Aug 16, 2026

fix: format WatchedSink and fix concurrent materialization race in Sink.watchTermination
He-Pin
committed
d9127e2