Как остановить поток реактора?

Question

У меня есть реактивное соединение с Redis, на которое я могу подписаться. У меня также есть веб-розетка, на которую я хочу передать свои события.

Для этого я сделал следующее, но я не знаю, как сказать подписчику написать сообщение на веб-буфете, можете ли вы мне помочь? ?

public class MySocketHandler extends TextWebSocketHandler  {

@Autowired
private ReactiveRedisMessageListenerContainer topicListener;


@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
    log.info("Look who's here!");
    topicListener.receive(Channel.of("mychannel")
      .map(msg -> new TextMessage(msg.getMessage())).
     //what to I put here to call session.sendMessage() and end the loop?

}