Detecting a disconnect. ReactiveWebSocketSubscriptionsHandler and ApolloSubscriptionConnectionListener

[pokebadgerswithspoon]

Hi!

I'm looking for a way to get notified on user disconnect. What is the right way to do it? Say detect a disconnection and notify other subscriptions that some user went offline.

My own findings are:

• ReactiveWebSocketSubscriptionsHandler
• ApolloSubscriptionConnectionListener

Looking at ReactiveWebSocketSubscriptionsHandler.java#L37 it is seen that subscriptionSession gets closed, but no calls to ApolloSubscriptionConnectionListener are made.

Could it be that ApolloSubscriptionConnectionListener::onClose is missing?

Refrerence

    Mono<Void> input = webSocketSession.receive()
        .map(WebSocketMessage::getPayloadAsText)
        .doOnNext(consumer)
        .doFinally((type) -> subscriptionSession.close(null))
        .then();