From e0bdb203f2596a65b6ce8c6fb939f82a6dc24048 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Sun, 17 Nov 2019 07:02:38 +0100
Subject: Implement future-based `Command` in `iced_core`

---
 core/src/command.rs | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create mode 100644 core/src/command.rs

(limited to 'core/src/command.rs')

diff --git a/core/src/command.rs b/core/src/command.rs
new file mode 100644
index 00000000..ae901bd8
--- /dev/null
+++ b/core/src/command.rs
@@ -0,0 +1,49 @@
+use futures::future::{BoxFuture, Future, FutureExt};
+
+pub struct Command<T> {
+    futures: Vec<BoxFuture<'static, T>>,
+}
+
+impl<T> Command<T> {
+    pub fn none() -> Self {
+        Self {
+            futures: Vec::new(),
+        }
+    }
+
+    pub fn attempt<A>(
+        future: impl Future<Output = T> + 'static + Send,
+        f: impl Fn(T) -> A + 'static + Send,
+    ) -> Command<A> {
+        Command {
+            futures: vec![future.map(f).boxed()],
+        }
+    }
+
+    pub fn batch(commands: impl Iterator<Item = Command<T>>) -> Self {
+        Self {
+            futures: commands.flat_map(|command| command.futures).collect(),
+        }
+    }
+
+    pub fn futures(self) -> Vec<BoxFuture<'static, T>> {
+        self.futures
+    }
+}
+
+impl<T, A> From<A> for Command<T>
+where
+    A: Future<Output = T> + 'static + Send,
+{
+    fn from(future: A) -> Self {
+        Self {
+            futures: vec![future.boxed()],
+        }
+    }
+}
+
+impl<T> std::fmt::Debug for Command<T> {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        f.debug_struct("Command").finish()
+    }
+}
-- 
cgit 


From a803ab240b9b5d1a073454f814229bad9d8bdafc Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Mon, 18 Nov 2019 00:10:40 +0100
Subject: Rename `Command::attempt` to `Command::perform`

---
 core/src/command.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'core/src/command.rs')

diff --git a/core/src/command.rs b/core/src/command.rs
index ae901bd8..e1c865dd 100644
--- a/core/src/command.rs
+++ b/core/src/command.rs
@@ -11,7 +11,7 @@ impl<T> Command<T> {
         }
     }
 
-    pub fn attempt<A>(
+    pub fn perform<A>(
         future: impl Future<Output = T> + 'static + Send,
         f: impl Fn(T) -> A + 'static + Send,
     ) -> Command<A> {
-- 
cgit