4 instantiations of PartitionedStreamMerger
System.Core (4)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
96PartitionedStreamMerger<TLeftInput> merger = new PartitionedStreamMerger<TLeftInput>( 106PartitionedStreamMerger<TRightInput> merger = new PartitionedStreamMerger<TRightInput>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
162PartitionedStreamMerger<TOutput> merger = new PartitionedStreamMerger<TOutput>(forEffect, mergeOptions.GetValueOrDefault(), 231new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.FullyBuffered, querySettings.TaskScheduler,
4 references to PartitionedStreamMerger
System.Core (4)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
96PartitionedStreamMerger<TLeftInput> merger = new PartitionedStreamMerger<TLeftInput>( 106PartitionedStreamMerger<TRightInput> merger = new PartitionedStreamMerger<TRightInput>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
162PartitionedStreamMerger<TOutput> merger = new PartitionedStreamMerger<TOutput>(forEffect, mergeOptions.GetValueOrDefault(), 230PartitionedStreamMerger<TOutput> merger =