Struct sans_io_runtime::bus::BusWorker

pub struct BusWorker<ChannelId, MSG, const STACK_SIZE: usize> { /* private fields */ }

Implementations

impl<ChannelId, MSG, const STACK_SIZE: usize> BusWorker<ChannelId, MSG, STACK_SIZE>

pub fn leg_index(&self) -> usize

pub fn recv(&self) -> Option<(BusEventSource<ChannelId>, MSG)>

pub fn set_awaker(&self, awaker: Arc<dyn Awaker>)

Trait Implementations

impl<ChannelId: Debug + Copy + Hash + PartialEq + Eq, MSG: Clone, const STACK_SIZE: usize> BusPubSubFeature<ChannelId, MSG> for BusWorker<ChannelId, MSG, STACK_SIZE>

fn subscribe(&self, channel: ChannelId)

fn unsubscribe(&self, channel: ChannelId)

fn publish(&self, channel: ChannelId, safe: bool, msg: MSG)

impl<ChannelId, MSG: Clone, const STACK_SIZE: usize> BusSendMultiFeature<MSG> for BusWorker<ChannelId, MSG, STACK_SIZE>

fn broadcast(&self, safe: bool, msg: MSG)

impl<ChannelId, MSG, const STACK_SIZE: usize> BusSendSingleFeature<MSG> for BusWorker<ChannelId, MSG, STACK_SIZE>

fn send_safe(&self, dest_leg: usize, msg: MSG) -> usize

fn send( &self, dest_leg: usize, safe: bool, msg: MSG, ) -> Result<usize, BusLegSenderErr>