diff options
| author | Dániel Buga <[email protected]> | 2025-06-16 13:57:19 +0200 |
|---|---|---|
| committer | Dániel Buga <[email protected]> | 2025-06-16 13:57:19 +0200 |
| commit | a0d17ea5ca0bd76ef4d4398c28bc8f98c4e50065 (patch) | |
| tree | 7508b417ffdefaa86b4afddba669d46c8d74f3fc /embassy-sync/src/pubsub/subscriber.rs | |
| parent | 56572ef0adffd6258adc10fb424e37a8b4ddc19c (diff) | |
Remove futures-util where unnecessary
Diffstat (limited to 'embassy-sync/src/pubsub/subscriber.rs')
| -rw-r--r-- | embassy-sync/src/pubsub/subscriber.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/embassy-sync/src/pubsub/subscriber.rs b/embassy-sync/src/pubsub/subscriber.rs index 6ad660cb3..649382cf1 100644 --- a/embassy-sync/src/pubsub/subscriber.rs +++ b/embassy-sync/src/pubsub/subscriber.rs | |||
| @@ -115,7 +115,7 @@ impl<'a, PSB: PubSubBehavior<T> + ?Sized, T: Clone> Unpin for Sub<'a, PSB, T> {} | |||
| 115 | 115 | ||
| 116 | /// Warning: The stream implementation ignores lag results and returns all messages. | 116 | /// Warning: The stream implementation ignores lag results and returns all messages. |
| 117 | /// This might miss some messages without you knowing it. | 117 | /// This might miss some messages without you knowing it. |
| 118 | impl<'a, PSB: PubSubBehavior<T> + ?Sized, T: Clone> futures_util::Stream for Sub<'a, PSB, T> { | 118 | impl<'a, PSB: PubSubBehavior<T> + ?Sized, T: Clone> futures_core::Stream for Sub<'a, PSB, T> { |
| 119 | type Item = T; | 119 | type Item = T; |
| 120 | 120 | ||
| 121 | fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { | 121 | fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { |
