smol-rs
/
blocking
mirror of https://github.com/smol-rs/blocking
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #25 from Neo-Zhixing/unblock_task 

unblock returns Task
This commit is contained in:
Taiki Endo 2022-03-13 00:10:58 +09:00 committed by GitHub
parent 2bb7954464 501cfc2d48
commit 4a775ebcb0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/lib.rs
View File

@ -93,7 +93,8 @@ use std::thread;
use std::time::Duration;
use async_channel::{bounded, Receiver};
use async_task::{Runnable, Task};
use async_task::Runnable;
pub use async_task::Task;
use atomic_waker::AtomicWaker;
use futures_lite::{future, prelude::*, ready};
use once_cell::sync::Lazy;
@ -267,12 +268,12 @@ impl Executor {
/// let out = unblock(|| Command::new("dir").output()).await?;
/// # std::io::Result::Ok(()) });
/// ```
pub async fn unblock<T, F>(f: F) -> T
pub fn unblock<T, F>(f: F) -> Task<T>
where
F: FnOnce() -> T + Send + 'static,
T: Send + 'static,
{
Executor::spawn(async move { f() }).await
Executor::spawn(async move { f() })
}
/// Runs blocking I/O on a thread pool.