依赖于父任务结果的链式异步函数

Question

我在这里尝试做的是基于父任务执行我尝试执行或取消后续异步任务。我发现很难围绕执行以下内容并尝试以最佳方式实现这一点。我正在寻找一种以最优化的方式编写此内容的方法。

另外，我很困惑为什么即使在抛出异常之后它仍会继续下一次迭代并等待任务找出抛出的异常。我找不到关于这个的解释。

 public static async Task<TOut> AndThen<TIn, TOut>(this Task<TIn> sourceTask, Func<TIn, Task<TOut>> sf, CancellationToken cancelToken)
 {
        return await sourceTask.ContinueWith(async st => {
            var res = await st; // Raising cancel request in here.
            cancelToken.ThrowIfCancellationRequested();
            return await sf(res);
        }, TaskContinuationOptions.NotOnFaulted & TaskContinuationOptions.NotOnCanceled).Unwrap();
 }

Answer 1

作为一般规则，don't use ContinueWith。请改用await：

public static async Task<TOut> AndThen<TIn, TOut>(this Task<TIn> sourceTask, Func<TIn, Task<TOut>> sf, CancellationToken cancelToken)
{
  var res = await st;
  cancelToken.ThrowIfCancellationRequested();
  return await sf(res);
}