max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fmt

Browse Source
This commit is contained in:
Dion Dokter 2022-06-17 15:08:31 +02:00
parent 949b548d45
commit 9887f18a51
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
embassy/src/channel/pubsub/mod.rs
View File

@ -341,12 +341,12 @@ pub enum Error {
/// This trait is used so that Sub and Pub can be generic over the channel. /// This trait is used so that Sub and Pub can be generic over the channel.
pub trait PubSubBehavior<T> { pub trait PubSubBehavior<T> {
/// Try to get a message from the queue with the given message id. /// Try to get a message from the queue with the given message id.
/// ///
/// If the message is not yet present and a context is given, then its waker is registered in the subsriber wakers. /// If the message is not yet present and a context is given, then its waker is registered in the subsriber wakers.
fn get_message_with_context(&self, next_message_id: &mut u64, cx: Option<&mut Context<'_>>) -> Poll<WaitResult<T>>; fn get_message_with_context(&self, next_message_id: &mut u64, cx: Option<&mut Context<'_>>) -> Poll<WaitResult<T>>;
/// Try to publish a message to the queue. /// Try to publish a message to the queue.
/// ///
/// If the queue is full and a context is given, then its waker is registered in the publisher wakers. /// If the queue is full and a context is given, then its waker is registered in the publisher wakers.
fn publish_with_context(&self, message: T, cx: Option<&mut Context<'_>>) -> Result<(), T>; fn publish_with_context(&self, message: T, cx: Option<&mut Context<'_>>) -> Result<(), T>;