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