pekko/stream
Andreas Lochbihler de12867f94
Avoid register/unregister race condition that can wipe elements from BroadcastHub (#1841)
* add test case to demonstrate that BroadcastHub drops elements

* fix the race condition with unregister (refs https://github.com/apache/pekko/issues/1836)

* address review comment: documentation and separate constructor instead of default arguments

* address review comments

* Update Hub.scala

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
2025-06-02 12:13:50 +01:00
..
src/main Avoid register/unregister race condition that can wipe elements from BroadcastHub (#1841) 2025-06-02 12:13:50 +01:00