From e0233ebc3ce4791d094c52eeef81cce78b9bc578 Mon Sep 17 00:00:00 2001
From: Ian Douglas Scott <idscott@system76.com>
Date: Thu, 3 Aug 2023 10:19:28 -0700
Subject: Fix `Command<T>::perform` to return a `Command<T>`

This seems like clearly the correct thing to do here. If the type bound
on `Command` isn't specified, it makes no difference, since the generic
is inferred in a way that works with either definition. But this is
important if `Command<T>` is aliased with a concrete type.
---
 runtime/src/command.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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

diff --git a/runtime/src/command.rs b/runtime/src/command.rs
index cd4c51ff..b74097bd 100644
--- a/runtime/src/command.rs
+++ b/runtime/src/command.rs
@@ -40,9 +40,9 @@ impl<T> Command<T> {
 
     /// Creates a [`Command`] that performs the action of the given future.
     pub fn perform<A>(
-        future: impl Future<Output = T> + 'static + MaybeSend,
-        f: impl FnOnce(T) -> A + 'static + MaybeSend,
-    ) -> Command<A> {
+        future: impl Future<Output = A> + 'static + MaybeSend,
+        f: impl FnOnce(A) -> T + 'static + MaybeSend,
+    ) -> Command<T> {
         use iced_futures::futures::FutureExt;
 
         Command::single(Action::Future(Box::pin(future.map(f))))
-- 
cgit 


From 3b7d479534d9114ed12bb5d9ccd910e85d5c13c7 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector@hecrj.dev>
Date: Wed, 29 Nov 2023 00:12:48 +0100
Subject: Implement `Command::run` for executing a `Stream` to completion

---
 runtime/src/command.rs | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

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

diff --git a/runtime/src/command.rs b/runtime/src/command.rs
index b74097bd..b942f3ce 100644
--- a/runtime/src/command.rs
+++ b/runtime/src/command.rs
@@ -4,8 +4,10 @@ mod action;
 pub use action::Action;
 
 use crate::core::widget;
+use crate::futures::futures;
 use crate::futures::MaybeSend;
 
+use futures::Stream;
 use std::fmt;
 use std::future::Future;
 
@@ -43,11 +45,21 @@ impl<T> Command<T> {
         future: impl Future<Output = A> + 'static + MaybeSend,
         f: impl FnOnce(A) -> T + 'static + MaybeSend,
     ) -> Command<T> {
-        use iced_futures::futures::FutureExt;
+        use futures::FutureExt;
 
         Command::single(Action::Future(Box::pin(future.map(f))))
     }
 
+    /// Creates a [`Command`] that runs the given stream to completion.
+    pub fn run<A>(
+        stream: impl Stream<Item = A> + 'static + MaybeSend,
+        f: impl Fn(A) -> T + 'static + MaybeSend,
+    ) -> Command<T> {
+        use futures::StreamExt;
+
+        Command::single(Action::Stream(Box::pin(stream.map(f))))
+    }
+
     /// Creates a [`Command`] that performs the actions of all the given
     /// commands.
     ///
-- 
cgit 


From a761448858521d11dc646e2ef5217e9e06628932 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector@hecrj.dev>
Date: Wed, 29 Nov 2023 00:14:27 +0100
Subject: Implement `command::channel` helper

It is analogous to `subscription::channel`.
---
 runtime/src/command.rs | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

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

diff --git a/runtime/src/command.rs b/runtime/src/command.rs
index b942f3ce..f70da915 100644
--- a/runtime/src/command.rs
+++ b/runtime/src/command.rs
@@ -7,6 +7,7 @@ use crate::core::widget;
 use crate::futures::futures;
 use crate::futures::MaybeSend;
 
+use futures::channel::mpsc;
 use futures::Stream;
 use std::fmt;
 use std::future::Future;
@@ -118,3 +119,23 @@ impl<T> fmt::Debug for Command<T> {
         command.fmt(f)
     }
 }
+
+/// Creates a [`Command`] that produces the `Message`s published from a [`Future`]
+/// to an [`mpsc::Sender`] with the given bounds.
+pub fn channel<Fut, Message>(
+    size: usize,
+    f: impl FnOnce(mpsc::Sender<Message>) -> Fut + MaybeSend + 'static,
+) -> Command<Message>
+where
+    Fut: Future<Output = ()> + MaybeSend + 'static,
+    Message: 'static + MaybeSend,
+{
+    use futures::future;
+    use futures::stream::{self, StreamExt};
+
+    let (sender, receiver) = mpsc::channel(size);
+
+    let runner = stream::once(f(sender)).filter_map(|_| future::ready(None));
+
+    Command::single(Action::Stream(Box::pin(stream::select(receiver, runner))))
+}
-- 
cgit