fix(sandside): #197 reset unicast to multicast for notification

Marthym · Dec 31, 2023 · 7ed1587 · 7ed1587
1 parent db0962d
commit 7ed1587
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sandside/src/main/java/fr/ght1pc9kc/baywatch/notify/domain/NotifyServiceImpl.java b/sandside/src/main/java/fr/ght1pc9kc/baywatch/notify/domain/NotifyServiceImpl.java
@@ -69,7 +69,7 @@ public Flux<ServerEvent> subscribe() {
         }
         return authFacade.getConnectedUser().flatMapMany(u ->
                 Objects.requireNonNull(cache.get(u.id, id -> {
-                    Sinks.Many<ServerEvent> sink = Sinks.many().unicast().onBackpressureBuffer();
+                    Sinks.Many<ServerEvent> sink = Sinks.many().multicast().onBackpressureBuffer();
                     AtomicReference<Subscription> subscription = new AtomicReference<>();
                     Flux<ServerEvent> multicastFlux = this.multicast.asFlux()
                             .doOnSubscribe(subscription::set);