我有一个通量，它在一个时间间隔内发出无限数量的值。我需要一个Websockets端点，它在客户端连接时发出通量的值。
目前我的体会如下：

@ServerWebSocket("/updates")
public class UpdateController {
    private Flux<Update> updates;
    
    // ... left out for brevity

    @OnOpen
    public Flux<Update> onOpen(WebSocketSession session) {
        return updates.flatMap(session::send);
    }

    @OnMessage
    public void onMessage(String content) {
        // do nothing
    }

    @OnClose
    public void onClose(WebSocketSession session) {
        // do nothing
    }
}

这是可行的，但是一旦客户端关闭连接，就会抛出一个异常。这对我来说是有意义的，因为updates Flux仍然会发出值，并且会调用session：：send。
但是我怎样才能在某种程度上构造我的代码，使这个异常不被抛出呢？我觉得我遗漏了一些东西。