This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch feat/sink-watch-termination
in repository https://gitbox.apache.org/repos/asf/pekko.git
from 5f5f9dd52e feat: support arbitrary composite sinks in
Sink.watchTermination
add d9127e264d fix: format WatchedSink and fix concurrent materialization
race in Sink.watchTermination
No new revisions were added by this update.
Summary of changes:
.../stream/scaladsl/SinkWatchTerminationSpec.scala | 27 ++++++++++++-
.../pekko/stream/impl/fusing/WatchedSink.scala | 45 ++++++++++++++--------
2 files changed, 53 insertions(+), 19 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
