Struct rtps::entity::StatelessReader

pub struct StatelessReader {
    pub writer_locators: Vec<(Locator, Option<EntityId>)>,
    // some fields omitted
}

Fields

writer_locators: Vec<(Locator, Option<EntityId>)>

Methods

impl StatelessReader

pub fn new(args: ReaderInitArgs) -> Result<Self>

pub fn reader_cache(&self) -> &HistoryCache

pub fn reader_cache_condvar(&self) -> Arc<(Mutex<bool>, Condvar)>

pub fn wait_for_reader_cache_change(&self)

Trait Implementations

impl ReaderTrait for StatelessReader

fn expects_inline_qos(&self) -> bool

fn heartbeat_response_delay(&self) -> Duration

fn heartbeat_supression_duration(&self) -> Duration

impl SpawnableTaskTrait for StatelessReader

fn werk(&mut self, buf: &mut [u8]) -> Result<()>

fn stop(&mut self)

fn join(self) -> Result<SpawnableTaskStats>

fn spawn(syncy_self: Arc<Mutex<Self>>) -> SpawnableTaskHandle where
    Self: Send,
    Self: 'static, 

impl EntityTrait for StatelessReader

fn guid(&self) -> Guid

impl EndpointTrait for StatelessReader

fn topic_kind(&self) -> TopicKind

fn set_socket(&mut self, sock: Arc<UdpSocket>)

fn unicast_locator_list(&self) -> &LocatorList

fn mut_unicast_locator_list(&mut self) -> &mut LocatorList

fn multicast_locator_list(&mut self) -> &mut LocatorList

fn reliability_level(&self) -> ReliabilityKind

fn start_listening(&mut self) -> Result<()>