code: private StateConnection readBody()
    {
      try {
        //_requestHttp.readBodyChunk(this);
  
        /*
        if (! _isBodyComplete) {
          // XXX: only on non-upgrade and non-101
          _requestHttp.readBodyChunk(this);
        }
        */
  
        if (! _isBodyComplete) {
          return StateConnection.READ;
        }
  
        requestProxy().bodyComplete(this);
  
        ServiceRef.flushOutboxAndExecuteLast();
  
        if (requestHttp().isKeepalive()) {
          return StateConnection.READ;
        }
        else {
          return StateConnection.CLOSE_READ_A;
        }
      } catch (Throwable e) {
        log.log(Level.WARNING, e.toString(), e);
  
        e.printStackTrace();
  
        toClose();
  
        return StateConnection.CLOSE;
      }
    }
docs: /*
  @Override
  public StateConnection service()
  {
  try {
  StateConnection nextState = _state.service(this);
  
  return StateConnection.CLOSE;
  return nextState;
  } catch (Throwable e) {
  log.log(Level.WARNING, e.toString(), e);
  e.printStackTrace();
  
  toClose();
  
  return StateConnection.CLOSE_READ_A;
  }
  }