ProcessMessage()

void System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >.ProcessMessage ( Func< TInput, TOutput > transform, KeyValuePair< TInput, long > messageWithId )

inlineprivate

Definition at line 162 of file TransformBlock.cs.

    {
        TOutput item = default(TOutput);
        bool flag = false;
        try
        {
            item = transform(messageWithId.Key);
            flag = true;
        }
        catch (Exception exception)
        {
            if (!Common.IsCooperativeCancellation(exception))
            {
                throw;
            }
        }
        finally
        {
            if (!flag)
            {
                _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);
            }
        }
    }

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.Threading.Tasks.Dataflow.Internal.Common.IsCooperativeCancellation(), System.item, and System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput >.ParallelSourceLock.