AsyncCompleteProcessMessageWithTask()

void System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.AsyncCompleteProcessMessageWithTask ( Task< IEnumerable< TOutput > > completed, KeyValuePair< TInput, long > messageWithId )

inlineprivate

Definition at line 227 of file TransformManyBlock.cs.

    {
        switch (completed.Status)
        {
        case TaskStatus.RanToCompletion:
        {
            IEnumerable<TOutput> result = completed.Result;
            try
            {
                StoreOutputItems(messageWithId, result);
            }
            catch (Exception ex)
            {
                if (!Common.IsCooperativeCancellation(ex))
                {
                    Common.StoreDataflowMessageValueIntoExceptionData(ex, messageWithId.Key);
                    _target.Complete(ex, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true);
                }
            }
            break;
        }
        case TaskStatus.Faulted:
        {
            AggregateException exception = completed.Exception;
            Common.StoreDataflowMessageValueIntoExceptionData(exception, messageWithId.Key, targetInnerExceptions: true);
            _target.Complete(exception, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true);
            goto case TaskStatus.Canceled;
        }
        case TaskStatus.Canceled:
            StoreOutputItems(messageWithId, null);
            break;
        }
        _target.SignalOneAsyncMessageCompleted();
    }

References System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >._target, System.exception, System.Threading.Tasks.Dataflow.Internal.Common.IsCooperativeCancellation(), and System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.StoreOutputItems().