Struct embassy_sync::pubsub::PubSubChannel
source · pub struct PubSubChannel<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usize> { /* private fields */ }
Expand description
A broadcast channel implementation where multiple publishers can send messages to multiple subscribers
Any published message can be read by all subscribers. A publisher can choose how it sends its message.
- With Pub::publish() the publisher has to wait until there is space in the internal message queue.
- With Pub::publish_immediate() the publisher doesn’t await and instead lets the oldest message in the queue drop if necessary. This will cause any Subscriber that missed the message to receive an error to indicate that it has lagged.
§Example
// Create the channel. This can be static as well
let channel = PubSubChannel::<NoopRawMutex, u32, 4, 4, 4>::new();
// This is a generic subscriber with a direct reference to the channel
let mut sub0 = channel.subscriber().unwrap();
// This is a dynamic subscriber with a dynamic (trait object) reference to the channel
let mut sub1 = channel.dyn_subscriber().unwrap();
let pub0 = channel.publisher().unwrap();
// Publish a message, but wait if the queue is full
pub0.publish(42).await;
// Publish a message, but if the queue is full, just kick out the oldest message.
// This may cause some subscribers to miss a message
pub0.publish_immediate(43);
// Wait for a new message. If the subscriber missed a message, the WaitResult will be a Lag result
assert_eq!(sub0.next_message().await, WaitResult::Message(42));
assert_eq!(sub1.next_message().await, WaitResult::Message(42));
// Wait again, but this time ignore any Lag results
assert_eq!(sub0.next_message_pure().await, 43);
assert_eq!(sub1.next_message_pure().await, 43);
// There's also a polling interface
assert_eq!(sub0.try_next_message(), None);
assert_eq!(sub1.try_next_message(), None);
Implementations§
source§impl<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usize> PubSubChannel<M, T, CAP, SUBS, PUBS>
impl<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usize> PubSubChannel<M, T, CAP, SUBS, PUBS>
sourcepub fn subscriber(&self) -> Result<Subscriber<'_, M, T, CAP, SUBS, PUBS>, Error>
pub fn subscriber(&self) -> Result<Subscriber<'_, M, T, CAP, SUBS, PUBS>, Error>
Create a new subscriber. It will only receive messages that are published after its creation.
If there are no subscriber slots left, an error will be returned.
sourcepub fn dyn_subscriber(&self) -> Result<DynSubscriber<'_, T>, Error>
pub fn dyn_subscriber(&self) -> Result<DynSubscriber<'_, T>, Error>
Create a new subscriber. It will only receive messages that are published after its creation.
If there are no subscriber slots left, an error will be returned.
sourcepub fn publisher(&self) -> Result<Publisher<'_, M, T, CAP, SUBS, PUBS>, Error>
pub fn publisher(&self) -> Result<Publisher<'_, M, T, CAP, SUBS, PUBS>, Error>
Create a new publisher
If there are no publisher slots left, an error will be returned.
sourcepub fn dyn_publisher(&self) -> Result<DynPublisher<'_, T>, Error>
pub fn dyn_publisher(&self) -> Result<DynPublisher<'_, T>, Error>
Create a new publisher
If there are no publisher slots left, an error will be returned.
sourcepub fn immediate_publisher(
&self
) -> ImmediatePublisher<'_, M, T, CAP, SUBS, PUBS>
pub fn immediate_publisher( &self ) -> ImmediatePublisher<'_, M, T, CAP, SUBS, PUBS>
Create a new publisher that can only send immediate messages. This kind of publisher does not take up a publisher slot.
sourcepub fn dyn_immediate_publisher(&self) -> DynImmediatePublisher<'_, T>
pub fn dyn_immediate_publisher(&self) -> DynImmediatePublisher<'_, T>
Create a new publisher that can only send immediate messages. This kind of publisher does not take up a publisher slot.