4 instantiations of PartitionedStreamMerger
System.Linq.Parallel (4)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
93PartitionedStreamMerger<TLeftInput> merger = new PartitionedStreamMerger<TLeftInput>( 104PartitionedStreamMerger<TRightInput> merger = new PartitionedStreamMerger<TRightInput>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
153PartitionedStreamMerger<TOutput> merger = new PartitionedStreamMerger<TOutput>(forEffect, mergeOptions.GetValueOrDefault(), 235new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.FullyBuffered, querySettings.TaskScheduler,
4 references to PartitionedStreamMerger
System.Linq.Parallel (4)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
93PartitionedStreamMerger<TLeftInput> merger = new PartitionedStreamMerger<TLeftInput>( 104PartitionedStreamMerger<TRightInput> merger = new PartitionedStreamMerger<TRightInput>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
153PartitionedStreamMerger<TOutput> merger = new PartitionedStreamMerger<TOutput>(forEffect, mergeOptions.GetValueOrDefault(), 234PartitionedStreamMerger<TOutput> merger =