Async Disposable.Create

Question

Disposable.Create需要Action作为参数。 Action在处理Rx订阅时运行。

当处理Rx订阅时，我想运行一些异步清理代码，但使用async() =>与Action与async void相同，我想避免这种情况。有关我为什么要避免这种情况的更多详细信息，请参阅here。

是否可以创建类似Disposable.AsyncCreate的东西，它接受Func<Task>而不是Action。如果是这样，我应该如何使用它作为CompositeDisposable的一部分？

或者还有其他模式用于处理异步处置吗？

Answer 1

你可以做这样的事情。我还不能肯定知道这是多么好：

public class DisposableAsync 
{ 
    private readonly IDisposable _disposable; 
    private readonly Func<Task> _asyncDisposalAction; 
    public DisposableAsync(IDisposable disposable, Func<Task> asyncDisposalAction) 
    { 
     _disposable = disposable; 
     _asyncDisposalAction = asyncDisposalAction; 
    } 

    public Task DisposeAsync() 
    { 
     _disposable.Dispose(); 
     return _asyncDisposalAction(); 
    } 
} 

public static class DisposableAsyncExtensions 
{ 
    public static DisposableAsync ToAsync(this IDisposable disposable, Func<Task> asyncDisposalAction) 
    { 
     return new DisposableAsync(disposable, asyncDisposalAction); 
    } 
} 

然后，您可以使用这样的：

async Task Go() 
{ 

    var o = Observable.Interval(TimeSpan.FromMilliseconds(100)); 
    var d = o 
     .Subscribe(i => Console.WriteLine($"{DateTime.Now.ToLongTimeString()}: {i}")) 
     .ToAsync(async() => 
     { 
      Console.WriteLine($"{DateTime.Now.ToLongTimeString()}: Dispose Beginning"); 
      await Task.Delay(1000); 
      Console.WriteLine($"{DateTime.Now.ToLongTimeString()}: Dispose Complete"); 
     }); 
    Console.Read(); 
    var t = d.DisposeAsync(); 
    Console.WriteLine($"{DateTime.Now.ToLongTimeString()}: Outside task, waiting for dispose to complete"); 
    await t; 
    Console.WriteLine($"{DateTime.Now.ToLongTimeString()}: Task Complete"); 

} 

该解决方案不会与using()语句的工作，和类DisposableAsync应有些鲁莽。除此之外，我无法想到它有什么问题，但我却对此置之不理。只是觉得有点哈克。

Answer 2

我不认为async() =>有你认为它存在的问题。

试试这个：

Action x = async() => 
{ 
    try 
    { 
     Console.WriteLine("Hello"); 
     await Task.Delay(TimeSpan.FromSeconds(2.0)); 
     throw new Exception("Wait"); 
    } 
    catch (Exception ex) 
    { 
     Console.WriteLine(ex.Message); 
    } 
    Console.WriteLine("Goodbye"); 
}; 

var d = Disposable.Create(x); 

d.Dispose(); 

它产生：

 
Hello 
Wait 
Goodbye