code: @Override
      public STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception {
          String m = new String(bodyPart.getBodyPartBytes(), charSet).trim();
          if (m.length() > 0) {
              String[] data = m.split("data:");
              for (String d : data) {
                  if (d.length() > 0)
                      TransportsUtil.invokeFunction(decoders, functions, d.getClass(), d, MESSAGE.name(), resolver);
                  unlockFuture();
              }
          }
          return STATE.CONTINUE;
      }
docs: {@inheritDoc}