private void handleOutstandingOperations ( final ChannelHandlerContext ctx ) { if ( sentRequestQueue . isEmpty ( ) ) { LOGGER . trace ( logIdent ( ctx , endpoint ) + "Not cancelling operations - sent queue is empty." ) ; return ; } LOGGER . debug ( logIdent ( ctx , endpoint ) + "Cancelling " + sentRequestQueue . size ( ) + " outstanding requests." ) ; while ( ! sentRequestQueue . isEmpty ( ) ) { REQUEST req = sentRequestQueue . poll ( ) ; try { sideEffectRequestToCancel ( req ) ; failSafe ( env ( ) . scheduler ( ) , moveResponseOut , req . observable ( ) , new RequestCancelledException ( "Request cancelled in-flight." ) ) ; } catch ( Exception ex ) { LOGGER . info ( "Exception thrown while cancelling outstanding operation: {}" , user ( req . toString ( ) ) , ex ) ; } } sentRequestTimings . clear ( ) ; }
Cancells any outstanding operations which are currently on the wire .