aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src/pubsub
diff options
context:
space:
mode:
authorDario Nieuwenhuis <[email protected]>2025-06-29 22:37:11 +0200
committerDario Nieuwenhuis <[email protected]>2025-07-04 00:23:22 +0200
commit72248a601a9ea28ac696f186e2cbe4c2f128a133 (patch)
tree109eca1e791766d62237056f9fa4a5a37a7b9d63 /embassy-sync/src/pubsub
parentb964bee302fc3631d14d73d9a9b406e7352cd550 (diff)
Update Rust nightly, stable.
Diffstat (limited to 'embassy-sync/src/pubsub')
-rw-r--r--embassy-sync/src/pubsub/mod.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/embassy-sync/src/pubsub/mod.rs b/embassy-sync/src/pubsub/mod.rs
index 606efff0a..9206b9383 100644
--- a/embassy-sync/src/pubsub/mod.rs
+++ b/embassy-sync/src/pubsub/mod.rs
@@ -88,7 +88,7 @@ impl<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usi
88 /// Create a new subscriber. It will only receive messages that are published after its creation. 88 /// Create a new subscriber. It will only receive messages that are published after its creation.
89 /// 89 ///
90 /// If there are no subscriber slots left, an error will be returned. 90 /// If there are no subscriber slots left, an error will be returned.
91 pub fn subscriber(&self) -> Result<Subscriber<M, T, CAP, SUBS, PUBS>, Error> { 91 pub fn subscriber(&self) -> Result<Subscriber<'_, M, T, CAP, SUBS, PUBS>, Error> {
92 self.inner.lock(|inner| { 92 self.inner.lock(|inner| {
93 let mut s = inner.borrow_mut(); 93 let mut s = inner.borrow_mut();
94 94
@@ -120,7 +120,7 @@ impl<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usi
120 /// Create a new publisher 120 /// Create a new publisher
121 /// 121 ///
122 /// If there are no publisher slots left, an error will be returned. 122 /// If there are no publisher slots left, an error will be returned.
123 pub fn publisher(&self) -> Result<Publisher<M, T, CAP, SUBS, PUBS>, Error> { 123 pub fn publisher(&self) -> Result<Publisher<'_, M, T, CAP, SUBS, PUBS>, Error> {
124 self.inner.lock(|inner| { 124 self.inner.lock(|inner| {
125 let mut s = inner.borrow_mut(); 125 let mut s = inner.borrow_mut();
126 126
@@ -151,13 +151,13 @@ impl<M: RawMutex, T: Clone, const CAP: usize, const SUBS: usize, const PUBS: usi
151 151
152 /// Create a new publisher that can only send immediate messages. 152 /// Create a new publisher that can only send immediate messages.
153 /// This kind of publisher does not take up a publisher slot. 153 /// This kind of publisher does not take up a publisher slot.
154 pub fn immediate_publisher(&self) -> ImmediatePublisher<M, T, CAP, SUBS, PUBS> { 154 pub fn immediate_publisher(&self) -> ImmediatePublisher<'_, M, T, CAP, SUBS, PUBS> {
155 ImmediatePublisher(ImmediatePub::new(self)) 155 ImmediatePublisher(ImmediatePub::new(self))
156 } 156 }
157 157
158 /// Create a new publisher that can only send immediate messages. 158 /// Create a new publisher that can only send immediate messages.
159 /// This kind of publisher does not take up a publisher slot. 159 /// This kind of publisher does not take up a publisher slot.
160 pub fn dyn_immediate_publisher(&self) -> DynImmediatePublisher<T> { 160 pub fn dyn_immediate_publisher(&self) -> DynImmediatePublisher<'_, T> {
161 DynImmediatePublisher(ImmediatePub::new(self)) 161 DynImmediatePublisher(ImmediatePub::new(self))
162 } 162 }
163 163