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