code: @Override
      public STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception {
          if (isBinary) {
              byte[] payload = bodyPart.getBodyPartBytes();
  
              if (!protocolReceived && !Utils.whiteSpace(payload)) {
                  protocolReceived = true;
              }
  
              if (protocolReceived) {
                  TransportsUtil.invokeFunction(decoders, functions, payload.getClass(), payload, MESSAGE.name(), resolver);
                  unlockFuture();
              }
          } else {
              String m = new String(bodyPart.getBodyPartBytes(), charSet);
  
              if (!protocolReceived) {
                  m = m.trim();
                  if (m.length() > 0) {
                      protocolReceived = true;
                  }
              }
  
              if (protocolReceived) {
                  TransportsUtil.invokeFunction(decoders, functions, m.getClass(), m, MESSAGE.name(), resolver);
                  unlockFuture();
              }
          }
  
          return AsyncHandler.STATE.CONTINUE;
      }
docs: {@inheritDoc}