1 instantiation of MergeExecutor
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
57
MergeExecutor<TInputOutput> mergeExecutor = new
MergeExecutor
<TInputOutput>();
9 references to MergeExecutor
System.Linq.Parallel (9)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
69
MergeExecutor
<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken);
82
MergeExecutor
<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount);
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
49
internal static
MergeExecutor
<TInputOutput> Execute<TKey>(
57
MergeExecutor
<TInputOutput> mergeExecutor = new MergeExecutor<TInputOutput>();
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (3)
23
private
MergeExecutor
<TOutput>? _mergeExecutor;
33
internal
MergeExecutor
<TOutput>? MergeExecutor
60
_mergeExecutor =
MergeExecutor
<TOutput>.Execute<TKey>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
289
MergeExecutor
<TOutput> executor =
MergeExecutor
<TOutput>.Execute<TKey>(