Class Reader

include/process/http.hpp:302–339

public:
  class Reader
  {
  public:
    // Returns data written to the pipe.
    // Returns an empty read when end-of-file is reached.
    // Returns Failure if the writer failed, or the read-end
    // is closed.
    Future<std::string> read();

    // Performs a series of asynchronous reads, until EOF is reached.
    // Returns the concatenated result of the reads.
    // Returns Failure if the writer failed, or the read-end
    // is closed.
    Future<std::string> readAll();

    // Closing the read-end of the pipe before the write-end closes
    // or fails will notify the writer that the reader is no longer
    // interested. Returns false if the read-end was already closed.
    bool close();

    // Comparison operators useful for checking connection equality.
    bool operator==(const Reader& other) const { return data == other.data; }
    bool operator!=(const Reader& other) const { return !(*this == other); }

  private:
    friend class Pipe;

    enum State
    {
      OPEN,
      CLOSED,
    };

    explicit Reader(const std::shared_ptr<Data>& _data)
      : data(_data) {}

    std::shared_ptr<Data> data;
  };

  class Writer
  {