2 instantiations of Producer
System.Linq.Parallel (2)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)
294_producerHeap.Insert(new Producer<TKey>(element.First, producer)); 329_producerHeap.ReplaceMax(new Producer<TKey>(element.First, lastProducer));
11 references to Producer
System.Linq.Parallel (11)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (11)
87private readonly IComparer<Producer<TKey>> _producerComparer; 140_producerComparer = (IComparer<Producer<TKey>>)(object)ProducerComparerInt.Instance; 189private sealed class ProducerComparer : IComparer<Producer<TKey>> 198public int Compare(Producer<TKey> x, Producer<TKey> y) 221private readonly FixedMaxHeap<Producer<TKey>> _producerHeap; 249internal OrderedPipeliningMergeEnumerator(OrderPreservingPipeliningMergeHelper<TOutput, TKey> mergeHelper, IComparer<Producer<TKey>> producerComparer) 255_producerHeap = new FixedMaxHeap<Producer<TKey>>(partitionCount, producerComparer); 527internal sealed class ProducerComparerInt : IComparer<Producer<int>> 533public int Compare(Producer<int> x, Producer<int> y)