diff options
| author | Dario Nieuwenhuis <[email protected]> | 2025-06-29 22:37:11 +0200 |
|---|---|---|
| committer | Dario Nieuwenhuis <[email protected]> | 2025-07-04 00:23:22 +0200 |
| commit | 72248a601a9ea28ac696f186e2cbe4c2f128a133 (patch) | |
| tree | 109eca1e791766d62237056f9fa4a5a37a7b9d63 /embassy-sync | |
| parent | b964bee302fc3631d14d73d9a9b406e7352cd550 (diff) | |
Update Rust nightly, stable.
Diffstat (limited to 'embassy-sync')
| -rw-r--r-- | embassy-sync/src/pubsub/mod.rs | 8 |
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 | ||
