Function connect

src/slave/http.cpp:4185–4204

Helper that reads data from `writer` and writes to `reader`. Returns a failed future if there are any errors reading or writing. The future is satisfied when we get a EOF. TODO(vinod): Move this to libprocess if this is more generally useful.

// The future is satisfied when we get a EOF.
// TODO(vinod): Move this to libprocess if this is more generally useful.
Future<Nothing> connect(Pipe::Reader reader, Pipe::Writer writer)
{
  return loop(
      None(),
      [=]() mutable {
        return reader.read();
      },
      [=](const string& chunk) mutable -> Future<ControlFlow<Nothing>> {
        if (chunk.empty()) {
          // EOF case.
          return Break();
        }

        if (!writer.write(chunk)) {
          return Failure("Write failed to the pipe");
        }

        return Continue();
      });
}


Future<Response> Http::launchNestedContainerSession(