Merge pull request #175 from michaelstonis/feature/async-reactive-com…

…mand

adds support for asynchronous reactive command subscriptions

src/R3/ReactiveCommand.cs

@@ -1,4 +1,4 @@
-using System.Runtime.CompilerServices;
+using System.Runtime.CompilerServices;
 using System.Windows.Input; // for XAML binding
 
 namespace R3;
@@ -26,6 +26,13 @@ public ReactiveCommand(Action<T> execute)
         this.subscription = this.Subscribe(execute);
     }
 
+    public ReactiveCommand(Func<T, CancellationToken, ValueTask> executeAsync, AwaitOperation awaitOperation = AwaitOperation.Sequential, bool configureAwait = true, bool cancelOnCompleted = true, int maxSequential = -1)
+    {
+        this.list = new FreeListCore<Subscription>(this);
+        this.canExecute = true;
+        this.subscription = this.SubscribeAwait(executeAsync, awaitOperation, configureAwait, cancelOnCompleted, maxSequential);
+    }
+
     public ReactiveCommand(Observable<bool> canExecuteSource, bool initialCanExecute)
     {
         this.list = new FreeListCore<Subscription>(this);
@@ -186,4 +193,18 @@ public static ReactiveCommand<Unit> ToReactiveCommand(this Observable<bool> canE
 
         return command;
     }
+
+    public static ReactiveCommand<T> ToReactiveCommand<T>(
+        this Observable<bool> canExecuteSource, Func<T, CancellationToken, ValueTask> executeAsync,
+        bool initialCanExecute = true,
+        AwaitOperation awaitOperation = AwaitOperation.Sequential, bool configureAwait = true,
+        bool cancelOnCompleted = true, int maxSequential = -1)
+    {
+        var command = new ReactiveCommand<T>(canExecuteSource, initialCanExecute);
+
+        var subscription = command.SubscribeAwait(async (x, ct) => await executeAsync(x, ct), awaitOperation, configureAwait, cancelOnCompleted, maxSequential);
+        command.CombineSubscription(subscription);
+
+        return command;
+    }
 }