link_output_stream.h

Go to the documentation of this file.

#pragma once
 
#include "roo_transport/link/internal/thread_safe/compile_guard.h"
#ifdef ROO_USE_THREADS
 
#include "roo_io/core/input_stream.h"
#include "roo_transport/link/internal/thread_safe/channel.h"
 
namespace roo_transport {
 
class LinkOutputStream : public roo_io::OutputStream {
 public:
  LinkOutputStream()
      : channel_(nullptr), my_stream_id_(0), status_(roo_io::kClosed) {}
 
  LinkOutputStream(Channel& channel, uint32_t my_stream_id)
      : channel_(&channel), my_stream_id_(my_stream_id), status_(roo_io::kOk) {}
 
  LinkOutputStream(const LinkOutputStream&) = delete;
  LinkOutputStream& operator=(const LinkOutputStream&) = delete;
 
  LinkOutputStream(LinkOutputStream&& other);
  LinkOutputStream& operator=(LinkOutputStream&& other);
 
  size_t write(const roo::byte* buf, size_t count) override;
 
  size_t tryWrite(const roo::byte* buf, size_t count) override;
 
  size_t availableForWrite();
 
  void flush() override;
 
  void close() override;
 
  roo_io::Status status() const override { return status_; }
 
 private:
  Channel* channel_;
  uint32_t my_stream_id_;
  roo_io::Status status_;
};
 
}  // namespace roo_transport
 
#endif  // ROO_USE_THREADS