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
..
java/org/apache/pekko/stream	fix: Change aggregateWithBoundary operator in javadsl to use Optional. (#1876)	2025-05-30 03:20:51 +08:00
java-jdk9-only/org/apache/pekko/stream/javadsl	=str Fix maybe throw for MinimalStage. (#822)	2023-12-02 17:42:25 +08:00
resources	Issue 203: Update the truststore/keystore for stream-tests (#301)	2023-04-28 19:29:38 +02:00
scala/org/apache/pekko/stream	Avoid register/unregister race condition that can wipe elements from BroadcastHub (#1841)	2025-06-02 12:13:50 +01:00
scala-jdk9-only/org/apache/pekko/stream/scaladsl	adjust ASF header (#450)	2023-06-22 14:19:26 +01:00