code: @Override
      public AsyncHandler.STATE onStatusReceived(HttpResponseStatus responseStatus) throws Exception {
          if (connectOperationFuture != null && !protocolEnabled) {
              connectOperationFuture.finishOrThrowException();
          }
  
          TransportsUtil.invokeFunction(TRANSPORT, decoders, functions, Request.TRANSPORT.class, name(), TRANSPORT.name(), resolver);
  
          errorHandled.set(false);
          closed.set(false);
  
          if (!protocolEnabled) {
              triggerOpen();
          }
  
          TransportsUtil.invokeFunction(MESSAGE, decoders, functions, Integer.class, new Integer(responseStatus.getStatusCode()), STATUS.name(), resolver);
  
          return AsyncHandler.STATE.CONTINUE;
      }
docs: {@inheritDoc}