StoreOutputItemsNonReorderedWithIteration()

void System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.StoreOutputItemsNonReorderedWithIteration ( IEnumerable< TOutput > outputItems )

inlineprivate

Definition at line 363 of file TransformManyBlock.cs.

    {
        bool flag = _target.DataflowBlockOptions.MaxDegreeOfParallelism == 1 || _reorderingBuffer != null;
        if (_target.IsBounded)
        {
            bool flag2 = false;
            try
            {
                foreach (TOutput outputItem in outputItems)
                {
                    if (flag2)
                    {
                        _target.ChangeBoundingCount(1);
                    }
                    else
                    {
                        flag2 = true;
                    }
                    if (flag)
                    {
                        _source.AddMessage(outputItem);
                        continue;
                    }
                    lock (ParallelSourceLock)
                    {
                        _source.AddMessage(outputItem);
                    }
                }
                return;
            }
            finally
            {
                if (!flag2)
                {
                    _target.ChangeBoundingCount(-1);
                }
            }
        }
        if (flag)
        {
            foreach (TOutput outputItem2 in outputItems)
            {
                _source.AddMessage(outputItem2);
            }
            return;
        }
        foreach (TOutput outputItem3 in outputItems)
        {
            lock (ParallelSourceLock)
            {
                _source.AddMessage(outputItem3);
            }
        }
    }

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

Referenced by System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.StoreOutputItems(), and System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.StoreOutputItemsReordered().