code: 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();
      }
docs: Cancells any outstanding operations which are currently on the wire.
  
  @param ctx the handler context.