code: @Override
      public void onThrowable(Throwable t) {
          if (CancellationException.class.isAssignableFrom(t.getClass())) return;
  
          if(request != null) {
          	logger.warn("StreamTransport notified with exception {} for request : {}", t, request.uri());
          }
          logger.warn("", t);
          status = Socket.STATUS.ERROR;
          connectFutureException(t);
  
          errorHandled.set(TransportsUtil.invokeFunction(ERROR, decoders, functions, t.getClass(), t, ERROR.name(), resolver));
      }
docs: {@inheritDoc}