OrderedPipeliningMergeEnumerator()

System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.OrderedPipeliningMergeEnumerator ( OrderPreservingPipeliningMergeHelper< TOutput, TKey > mergeHelper, IComparer< Producer< TKey > > producerComparer )

inlinepackage

Definition at line 46 of file OrderPreservingPipeliningMergeHelper.cs.

            : base(mergeHelper._taskGroupState)
        {
            int partitionCount = mergeHelper._partitions.PartitionCount;
            _mergeHelper = mergeHelper;
            _producerHeap = new FixedMaxHeap<Producer<TKey>>(partitionCount, producerComparer);
            _privateBuffer = new Queue<Pair<TKey, TOutput>>[partitionCount];
            _producerNextElement = new TOutput[partitionCount];
        }

References System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._mergeHelper, System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._privateBuffer, System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._producerHeap, and System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._producerNextElement.