@ SuppressWarnings ( "unchecked" ) private void handleResponseSuccess ( long requestId , Object response ) { ContextualFuture future = responseFutures . remove ( requestId ) ; if ( future != null ) { future . context . executor ( ) . execute ( ( ) -> future . complete ( response ) ) ; } }
Handles a successful response .