aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src/pubsub
diff options
context:
space:
mode:
authorDániel Buga <[email protected]>2025-06-16 13:57:19 +0200
committerDániel Buga <[email protected]>2025-06-16 13:57:19 +0200
commita0d17ea5ca0bd76ef4d4398c28bc8f98c4e50065 (patch)
tree7508b417ffdefaa86b4afddba669d46c8d74f3fc /embassy-sync/src/pubsub
parent56572ef0adffd6258adc10fb424e37a8b4ddc19c (diff)
Remove futures-util where unnecessary
Diffstat (limited to 'embassy-sync/src/pubsub')
-rw-r--r--embassy-sync/src/pubsub/subscriber.rs2
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.
118impl<'a, PSB: PubSubBehavior<T> + ?Sized, T: Clone> futures_util::Stream for Sub<'a, PSB, T> { 118impl<'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>> {