local_data_stream.hpp

#ifndef SKYWAY_MEDIA_STREAM_INTERFACE_LOCAL_LOCAL_DATA_STREAM_HPP_
#define SKYWAY_MEDIA_STREAM_INTERFACE_LOCAL_LOCAL_DATA_STREAM_HPP_
 
#include <cstddef>
#include <cstdint>
#include <optional>
#include <string>
 
#include "skyway/media/stream/interface/local/local_stream.hpp"
 
namespace skyway {
namespace media {
namespace stream {
namespace interface {
namespace local {
 
class LocalDataStream : public LocalStream {
public:
    struct Subscriber {
        std::string id;
        std::optional<std::string> name;
    };
 
    class Listener {
    public:
        virtual ~Listener() = default;
 
        virtual void OnWritable(const Subscriber& subscriber) = 0;
 
        virtual void OnUnwritable(const Subscriber& subscriber) = 0;
    };
 
    virtual ~LocalDataStream() = default;
 
    virtual bool Write(const std::string& data) const = 0;
 
    virtual bool Write(const uint8_t* data, size_t length) const = 0;
 
    virtual void AddListener(Listener* listener) = 0;
 
    virtual void RemoveListener() = 0;
};
 
}  // namespace local
}  // namespace interface
}  // namespace stream
}  // namespace media
}  // namespace skyway
 
#endif  // SKYWAY_MEDIA_STREAM_INTERFACE_LOCAL_LOCAL_DATA_STREAM_HPP_