bert/beul
1
0
Fork 0
mirror of https://github.com/bertptrs/beul.git synced 2025-12-25 12:40:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

Make use of pin! stabilization

Browse Source
This commit is contained in:
Bert Peters
2023-03-11 11:50:01 +01:00
parent a0966f70e9
commit 44fe3f0e76
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/lib.rs
View File

@@ -16,6 +16,7 @@
//! ``` //! ```
#![forbid(unsafe_code)] #![forbid(unsafe_code)]
use std::future::Future; use std::future::Future;
use std::pin::Pin;
use std::sync::Arc; use std::sync::Arc;
use std::sync::Condvar; use std::sync::Condvar;
use std::sync::Mutex; use std::sync::Mutex;
@@ -60,10 +61,15 @@ impl Wake for CondvarWake {
} }
/// Block on specified [`Future`]. /// Block on specified [`Future`].
///
/// The future will be polled until completion on the current thread.
pub fn execute<T>(f: impl Future<Output = T>) -> T { pub fn execute<T>(f: impl Future<Output = T>) -> T {
// TODO: replace with std::pin::pin once it gets stabilized // Use dynamic dispatch to save on codegen
let mut pinned = Box::pin(f); poll(std::pin::pin!(f))
}
/// Poll a future until completion.
fn poll<T>(mut pinned: Pin<&mut dyn Future<Output = T>>) -> T {
let wake = Arc::new(CondvarWake::default()); let wake = Arc::new(CondvarWake::default());
let waker = Waker::from(Arc::clone(&wake)); let waker = Waker::from(Arc::clone(&wake));