question: @ Override public synchronized CompletableFuture < Void > disconnect ( ) { closeFuture = new CompletableFuture < > ( ) ; if ( ! consumers . isEmpty ( ) ) { consumers . forEach ( null ) ; if ( havePendingRead && cursor . cancelPendingReadRequest ( ) ) { havePendingRead = false ; } } else { closeFuture . complete ( null ) ; } return closeFuture ; }
target:  Disconnect all consumers on this dispatcher (server side close). This triggers channelInactive on the inbound handler which calls dispatcher.removeConsumer(), where the closeFuture is completed