AsyncCompleteProcessMessageWithTask()

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

inlineprivate

Definition at line 243 of file TransformBlock.cs.

    {
        bool isBounded = _target.IsBounded;
        bool flag = false;
        TOutput item = default(TOutput);
        switch (completed.Status)
        {
        case TaskStatus.RanToCompletion:
            item = completed.Result;
            flag = 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);
            break;
        }
        }
        if (!flag && isBounded)
        {
            _target.ChangeBoundingCount(-1);
        }
        if (_reorderingBuffer == null)
        {
            if (flag)
            {
                if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1)
                {
                    _source.AddMessage(item);
                }
                else
                {
                    lock (ParallelSourceLock)
                    {
                        _source.AddMessage(item);
                    }
                }
            }
        }
        else
        {
            _reorderingBuffer.AddItem(messageWithId.Value, item, flag);
        }
        _target.SignalOneAsyncMessageCompleted();
    }

References System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >._reorderingBuffer, System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >._source, System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >._target, System.exception, System.item, and System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >.ParallelSourceLock.