StoreOutputItemsNonReorderedAtomic()

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

inlineprivate

Definition at line 346 of file TransformManyBlock.cs.

    {
        if (_target.IsBounded)
        {
            UpdateBoundingCountWithOutputCount(((ICollection<TOutput>)outputItems).Count);
        }
        if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1)
        {
            _source.AddMessages(outputItems);
            return;
        }
        lock (ParallelSourceLock)
        {
            _source.AddMessages(outputItems);
        }
    }

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

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