Struct ChannelQueue 

pub struct ChannelQueue { /* private fields */ }

Implementations

impl ChannelQueue

pub const fn new(id: ChannelId, sender: Sender<ChannelMessage>) -> Self

pub const fn id(&self) -> ChannelId

pub fn broadcast<T: MessageMinimal>( &self, msg: T, receive_timestamp: u64, ) -> DigitalisResult<()>

pub fn subscribe( &self, client: Client, id: SubscriptionId, ) -> DigitalisResult<()>

pub fn unsubscribe( &self, client_id: ClientId, ids: Arc<Vec<SubscriptionId>>, ) -> DigitalisResult<()>

pub fn unsubscribe_all(&self, client_id: ClientId) -> DigitalisResult<()>

pub fn terminate(&self) -> DigitalisResult<()>

Trait Implementations

impl Clone for ChannelQueue

fn clone(&self) -> ChannelQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChannelQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.