12 #ifndef ROC_PIPELINE_RECEIVER_ENDPOINT_H_
13 #define ROC_PIPELINE_RECEIVER_ENDPOINT_H_
#define ROC_ATTR_NODISCARD
Emit warning if function result is not checked.
IArena & arena() const
Get arena.
Base class for list element.
Thread-safe lock-free node-based intrusive multi-producer single-consumer queue.
Optionally constructed object.
Base class for object with reference counter.
Receiver endpoint sub-pipeline.
ReceiverEndpoint(address::Protocol proto, ReceiverState &receiver_state, ReceiverSessionGroup &session_group, const rtp::FormatMap &format_map, core::IArena &arena)
Initialize.
ROC_ATTR_NODISCARD status::StatusCode pull_packets()
Pull packets writter to endpoint writer.
packet::IWriter & writer()
Get endpoint writer.
address::Protocol proto() const
Get protocol.
bool is_valid() const
Check if the port pipeline was succefully constructed.
Receiver pipeline state. Thread-safe.
Multi-producer single-consumer queue.
Optionally constructed object.
Base class for object with reference counter.