Reactor core 3 , webflux & websocket, send to specific session id
Clash Royale CLAN TAG #URR8PPP Reactor core 3 , webflux & websocket, send to specific session id Every session data passed into the socket is broadcasted to all users since every session subscribes to the UnicastProcessor eventPublisher. How can I send by event data to a single session id and not to all of them? @Override public Mono<Void> handle(WebSocketSession session) { WebSocketMessageSubscriber subscriber = new WebSocketMessageSubscriber(eventPublisher); session.receive() .map(WebSocketMessage::getPayloadAsText) .map(this::toEvent) .subscribe(subscriber::onNext, subscriber::onError, subscriber::onComplete); return session.send(outputEvents.map(session::textMessage)); } My use-case requires me to include both options for broadcasting any changed state with any client to all sockets connected plus the abillity to send response to a specific client (sessionId) that send a request within a specific event Github link or should...