A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
Loading...
Searching...
No Matches
a11::service::Session::StreamState Struct Reference

Public Member Functions

 StreamState (std::shared_ptr< net::WireStream > value, std::string value_id, std::shared_ptr< actions::ActionLimiter > gate)
 

Public Attributes

std::shared_ptr< net::WireStreamstream
 
std::string id
 
std::shared_ptr< actions::ActionLimiteraction_gate
 
size_t outstanding_messages = 0
 
size_t outstanding_bytes = 0
 
std::deque< std::pair< data::WireMessage, size_t > > pending_messages
 
bool message_pump_running = false
 
std::function< void()> message_pump_cancel
 
bool accepting_messages = true
 
bool remote_half_closed = false
 
bool half_close_delivered = false
 
bool done_started = false
 
bool done = false
 

Constructor & Destructor Documentation

◆ StreamState()

a11::service::Session::StreamState::StreamState ( std::shared_ptr< net::WireStream value,
std::string  value_id,
std::shared_ptr< actions::ActionLimiter gate 
)
inline

Member Data Documentation

◆ accepting_messages

bool a11::service::Session::StreamState::accepting_messages = true

◆ action_gate

std::shared_ptr<actions::ActionLimiter> a11::service::Session::StreamState::action_gate

◆ done

bool a11::service::Session::StreamState::done = false

◆ done_started

bool a11::service::Session::StreamState::done_started = false

◆ half_close_delivered

bool a11::service::Session::StreamState::half_close_delivered = false

◆ id

std::string a11::service::Session::StreamState::id

◆ message_pump_cancel

std::function<void()> a11::service::Session::StreamState::message_pump_cancel

◆ message_pump_running

bool a11::service::Session::StreamState::message_pump_running = false

◆ outstanding_bytes

size_t a11::service::Session::StreamState::outstanding_bytes = 0

◆ outstanding_messages

size_t a11::service::Session::StreamState::outstanding_messages = 0

◆ pending_messages

std::deque<std::pair<data::WireMessage, size_t> > a11::service::Session::StreamState::pending_messages

◆ remote_half_closed

bool a11::service::Session::StreamState::remote_half_closed = false

◆ stream

std::shared_ptr<net::WireStream> a11::service::Session::StreamState::stream

The documentation for this struct was generated from the following file: