aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src
diff options
context:
space:
mode:
authorDario Nieuwenhuis <[email protected]>2022-09-22 16:42:49 +0200
committerDario Nieuwenhuis <[email protected]>2022-09-22 16:42:49 +0200
commita0487380da42a71ab7532e2bc1befd1039c18a78 (patch)
treebb235fc3ba54f31838f3b546f7b4734ee8b42558 /embassy-sync/src
parent897b72c872183221e088611aa6f30989800afd2b (diff)
Replace futures::future::poll_fn -> core::future::poll_fn.
Diffstat (limited to 'embassy-sync/src')
-rw-r--r--embassy-sync/src/mutex.rs3
-rw-r--r--embassy-sync/src/signal.rs4
2 files changed, 3 insertions, 4 deletions
diff --git a/embassy-sync/src/mutex.rs b/embassy-sync/src/mutex.rs
index 92101c6b5..fcf056d36 100644
--- a/embassy-sync/src/mutex.rs
+++ b/embassy-sync/src/mutex.rs
@@ -2,11 +2,10 @@
2//! 2//!
3//! This module provides a mutex that can be used to synchronize data between asynchronous tasks. 3//! This module provides a mutex that can be used to synchronize data between asynchronous tasks.
4use core::cell::{RefCell, UnsafeCell}; 4use core::cell::{RefCell, UnsafeCell};
5use core::future::poll_fn;
5use core::ops::{Deref, DerefMut}; 6use core::ops::{Deref, DerefMut};
6use core::task::Poll; 7use core::task::Poll;
7 8
8use futures_util::future::poll_fn;
9
10use crate::blocking_mutex::raw::RawMutex; 9use crate::blocking_mutex::raw::RawMutex;
11use crate::blocking_mutex::Mutex as BlockingMutex; 10use crate::blocking_mutex::Mutex as BlockingMutex;
12use crate::waitqueue::WakerRegistration; 11use crate::waitqueue::WakerRegistration;
diff --git a/embassy-sync/src/signal.rs b/embassy-sync/src/signal.rs
index 34201d03a..b4d99513a 100644
--- a/embassy-sync/src/signal.rs
+++ b/embassy-sync/src/signal.rs
@@ -1,6 +1,6 @@
1//! A synchronization primitive for passing the latest value to a task. 1//! A synchronization primitive for passing the latest value to a task.
2use core::cell::UnsafeCell; 2use core::cell::UnsafeCell;
3use core::future::Future; 3use core::future::{poll_fn, Future};
4use core::mem; 4use core::mem;
5use core::task::{Context, Poll, Waker}; 5use core::task::{Context, Poll, Waker};
6 6
@@ -94,7 +94,7 @@ impl<T: Send> Signal<T> {
94 94
95 /// Future that completes when this Signal has been signaled. 95 /// Future that completes when this Signal has been signaled.
96 pub fn wait(&self) -> impl Future<Output = T> + '_ { 96 pub fn wait(&self) -> impl Future<Output = T> + '_ {
97 futures_util::future::poll_fn(move |cx| self.poll_wait(cx)) 97 poll_fn(move |cx| self.poll_wait(cx))
98 } 98 }
99 99
100 /// non-blocking method to check whether this signal has been signaled. 100 /// non-blocking method to check whether this signal has been signaled.