diff options
Diffstat (limited to 'futures/src/executor')
-rw-r--r-- | futures/src/executor/async_std.rs | 18 | ||||
-rw-r--r-- | futures/src/executor/null.rs | 19 | ||||
-rw-r--r-- | futures/src/executor/smol.rs | 18 | ||||
-rw-r--r-- | futures/src/executor/thread_pool.rs | 17 | ||||
-rw-r--r-- | futures/src/executor/tokio.rs | 22 | ||||
-rw-r--r-- | futures/src/executor/wasm_bindgen.rs | 15 |
6 files changed, 0 insertions, 109 deletions
diff --git a/futures/src/executor/async_std.rs b/futures/src/executor/async_std.rs deleted file mode 100644 index 471be369..00000000 --- a/futures/src/executor/async_std.rs +++ /dev/null @@ -1,18 +0,0 @@ -use crate::Executor; - -use futures::Future; - -/// An `async-std` runtime. -#[cfg_attr(docsrs, doc(cfg(feature = "async-std")))] -#[derive(Debug)] -pub struct AsyncStd; - -impl Executor for AsyncStd { - fn new() -> Result<Self, futures::io::Error> { - Ok(Self) - } - - fn spawn(&self, future: impl Future<Output = ()> + Send + 'static) { - let _ = async_std::task::spawn(future); - } -} diff --git a/futures/src/executor/null.rs b/futures/src/executor/null.rs deleted file mode 100644 index 65e2e2df..00000000 --- a/futures/src/executor/null.rs +++ /dev/null @@ -1,19 +0,0 @@ -use crate::Executor; - -use futures::Future; - -/// An executor that drops all the futures, instead of spawning them. -#[derive(Debug)] -pub struct Null; - -impl Executor for Null { - fn new() -> Result<Self, futures::io::Error> { - Ok(Self) - } - - #[cfg(not(target_arch = "wasm32"))] - fn spawn(&self, _future: impl Future<Output = ()> + Send + 'static) {} - - #[cfg(target_arch = "wasm32")] - fn spawn(&self, _future: impl Future<Output = ()> + 'static) {} -} diff --git a/futures/src/executor/smol.rs b/futures/src/executor/smol.rs deleted file mode 100644 index deafd43a..00000000 --- a/futures/src/executor/smol.rs +++ /dev/null @@ -1,18 +0,0 @@ -use crate::Executor; - -use futures::Future; - -/// A `smol` runtime. -#[cfg_attr(docsrs, doc(cfg(feature = "smol")))] -#[derive(Debug)] -pub struct Smol; - -impl Executor for Smol { - fn new() -> Result<Self, futures::io::Error> { - Ok(Self) - } - - fn spawn(&self, future: impl Future<Output = ()> + Send + 'static) { - smol::spawn(future).detach(); - } -} diff --git a/futures/src/executor/thread_pool.rs b/futures/src/executor/thread_pool.rs deleted file mode 100644 index a6c6168e..00000000 --- a/futures/src/executor/thread_pool.rs +++ /dev/null @@ -1,17 +0,0 @@ -use crate::Executor; - -use futures::Future; - -/// A thread pool runtime for futures. -#[cfg_attr(docsrs, doc(cfg(feature = "thread-pool")))] -pub type ThreadPool = futures::executor::ThreadPool; - -impl Executor for futures::executor::ThreadPool { - fn new() -> Result<Self, futures::io::Error> { - futures::executor::ThreadPool::new() - } - - fn spawn(&self, future: impl Future<Output = ()> + Send + 'static) { - self.spawn_ok(future); - } -} diff --git a/futures/src/executor/tokio.rs b/futures/src/executor/tokio.rs deleted file mode 100644 index c6a21cec..00000000 --- a/futures/src/executor/tokio.rs +++ /dev/null @@ -1,22 +0,0 @@ -use crate::Executor; - -use futures::Future; - -/// A `tokio` runtime. -#[cfg_attr(docsrs, doc(cfg(feature = "tokio")))] -pub type Tokio = tokio::runtime::Runtime; - -impl Executor for Tokio { - fn new() -> Result<Self, futures::io::Error> { - tokio::runtime::Runtime::new() - } - - fn spawn(&self, future: impl Future<Output = ()> + Send + 'static) { - let _ = tokio::runtime::Runtime::spawn(self, future); - } - - fn enter<R>(&self, f: impl FnOnce() -> R) -> R { - let _guard = tokio::runtime::Runtime::enter(self); - f() - } -} diff --git a/futures/src/executor/wasm_bindgen.rs b/futures/src/executor/wasm_bindgen.rs deleted file mode 100644 index 94d694c8..00000000 --- a/futures/src/executor/wasm_bindgen.rs +++ /dev/null @@ -1,15 +0,0 @@ -use crate::Executor; - -/// A `wasm-bindgen-futures` runtime. -#[derive(Debug)] -pub struct WasmBindgen; - -impl Executor for WasmBindgen { - fn new() -> Result<Self, futures::io::Error> { - Ok(Self) - } - - fn spawn(&self, future: impl futures::Future<Output = ()> + 'static) { - wasm_bindgen_futures::spawn_local(future); - } -} |