aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync
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
parent56572ef0adffd6258adc10fb424e37a8b4ddc19c (diff)
Remove futures-util where unnecessary
Diffstat (limited to 'embassy-sync')
-rw-r--r--embassy-sync/Cargo.toml2
-rw-r--r--embassy-sync/src/channel.rs4
-rw-r--r--embassy-sync/src/pubsub/subscriber.rs2
3 files changed, 4 insertions, 4 deletions
diff --git a/embassy-sync/Cargo.toml b/embassy-sync/Cargo.toml
index 99962f9f6..1e2ea8ea1 100644
--- a/embassy-sync/Cargo.toml
+++ b/embassy-sync/Cargo.toml
@@ -28,7 +28,7 @@ defmt = { version = "1.0.1", optional = true }
28log = { version = "0.4.14", optional = true } 28log = { version = "0.4.14", optional = true }
29 29
30futures-sink = { version = "0.3", default-features = false, features = [] } 30futures-sink = { version = "0.3", default-features = false, features = [] }
31futures-util = { version = "0.3.17", default-features = false } 31futures-core = { version = "0.3.31", default-features = false }
32critical-section = "1.1" 32critical-section = "1.1"
33heapless = "0.8" 33heapless = "0.8"
34cfg-if = "1.0.0" 34cfg-if = "1.0.0"
diff --git a/embassy-sync/src/channel.rs b/embassy-sync/src/channel.rs
index 856551417..dda91c651 100644
--- a/embassy-sync/src/channel.rs
+++ b/embassy-sync/src/channel.rs
@@ -443,7 +443,7 @@ where
443 } 443 }
444} 444}
445 445
446impl<'ch, M, T, const N: usize> futures_util::Stream for Receiver<'ch, M, T, N> 446impl<'ch, M, T, const N: usize> futures_core::Stream for Receiver<'ch, M, T, N>
447where 447where
448 M: RawMutex, 448 M: RawMutex,
449{ 449{
@@ -962,7 +962,7 @@ where
962 } 962 }
963} 963}
964 964
965impl<M, T, const N: usize> futures_util::Stream for Channel<M, T, N> 965impl<M, T, const N: usize> futures_core::Stream for Channel<M, T, N>
966where 966where
967 M: RawMutex, 967 M: RawMutex,
968{ 968{
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>> {