Merge pull request #164 from hecrj/feature/custom-runtime

Custom futures executor with `iced_futures`

1 files changed, 54 insertions, 0 deletions

diff --git a/src/executor.rs b/src/executor.rs
new file mode 100644
index 00000000..cbbd8283
--- /dev/null
+++ b/src/executor.rs
@@ -0,0 +1,54 @@
+//! Choose your preferred executor to power your application.
+pub use crate::common::{executor::Null, Executor};
+
+pub use platform::Default;
+
+#[cfg(not(target_arch = "wasm32"))]
+mod platform {
+    use iced_winit::{executor::ThreadPool, futures, Executor};
+
+    /// A default cross-platform executor.
+    ///
+    /// - On native platforms, it will use a `iced_futures::executor::ThreadPool`.
+    /// - On the Web, it will use `iced_futures::executor::WasmBindgen`.
+    #[derive(Debug)]
+    pub struct Default(ThreadPool);
+
+    impl Executor for Default {
+        fn new() -> Result<Self, futures::io::Error> {
+            Ok(Default(ThreadPool::new()?))
+        }
+
+        fn spawn(
+            &self,
+            future: impl futures::Future<Output = ()> + Send + 'static,
+        ) {
+            self.0.spawn(future);
+        }
+    }
+}
+
+#[cfg(target_arch = "wasm32")]
+mod platform {
+    use iced_web::{executor::WasmBindgen, futures, Executor};
+
+    /// A default cross-platform executor.
+    ///
+    /// - On native platforms, it will use a `iced_futures::executor::ThreadPool`.
+    /// - On the Web, it will use `iced_futures::executor::WasmBindgen`.
+    #[derive(Debug)]
+    pub struct Default(WasmBindgen);
+
+    impl Executor for Default {
+        fn new() -> Result<Self, futures::io::Error> {
+            Ok(Default(WasmBindgen::new()?))
+        }
+
+        fn spawn(
+            &self,
+            future: impl futures::Future<Output = ()> + Send + 'static,
+        ) {
+            self.0.spawn(future);
+        }
+    }
+}