Method read

3rdparty/libprocess/src/http.cpp:459–478

Future<string> Pipe::Reader::read()
{
  synchronized (data->lock) {
    if (data->readEnd == Reader::CLOSED) {
      return Failure("closed");
    } else if (!data->writes.empty()) {
      Future<string> future = data->writes.front();
      data->writes.pop();
      return future;
    } else if (data->writeEnd == Writer::CLOSED) {
      return ""; // End-of-file.
    } else if (data->writeEnd == Writer::FAILED) {
      CHECK_SOME(data->failure);
      return data->failure.get();
    } else {
      data->reads.push(Owned<Promise<string>>(new Promise<string>()));
      return data->reads.back()->future();
    }
  }
}


Future<string> Pipe::Reader::readAll()