firesse/stream.h

#pragma once

#include <memory>

#include "firecgi/request.h"

namespace firesse {

class Index;

class Stream {
 public:
  Stream(firecgi::Request* request, Index* index);
  ~Stream();

  void OnClose(const std::function<void()>& callback);

  bool WriteEvent(const std::string_view& data, uint64_t id = 0,
                  const std::string& type = "");
  bool WriteRaw(const std::string_view& data);
  bool End();
  void Close();

 private:
  firecgi::Request* request_;
  Index* index_;

  std::function<void()> on_close_;

  // TODO: What exactly is this protecting?
  std::recursive_mutex mu_;
  std::chrono::steady_clock::time_point last_message_time_;
  Stream* fresher_;
  Stream* staler_;

  friend class Index;
};

}  // namespace firesse