44 types derived from QueryOperatorEnumerator
System.Linq.Parallel (44)
System\Linq\Parallel\Enumerables\EmptyEnumerable.cs (1)
42internal sealed class EmptyEnumerator<T> : QueryOperatorEnumerator<T, int>, IEnumerator<T>
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
74private sealed class RangeEnumerator : QueryOperatorEnumerator<int, int>
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (1)
80private sealed class RepeatEnumerator : QueryOperatorEnumerator<TResult, int>
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
24internal sealed class HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey> : QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, int>
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)
25internal sealed class OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey> : QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, TOrderKey>
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
212internal sealed class ArrayIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 331internal sealed class ArrayContiguousIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 383internal sealed class ListIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 502internal sealed class ListContiguousIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 558private sealed class ContiguousChunkLazyEnumerator : QueryOperatorEnumerator<T, int>
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
225private sealed class AssociativeAggregationOperatorEnumerator<TKey> : QueryOperatorEnumerator<TIntermediate, int>
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (1)
158private sealed class ConcatQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TSource, ConcatKey<TLeftKey, TRightKey>>
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
137private sealed class ExceptQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, int> 227private sealed class OrderedExceptQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, TLeftKey>
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (1)
39: QueryOperatorEnumerator<TOutput, TOutputKey>
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
126private sealed class IntersectQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, int> 228private sealed class OrderedIntersectQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, TLeftKey>
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
183private sealed class UnionQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TInputOutput, int> 292private sealed class OrderedUnionQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TInputOutput, ConcatKey<TLeftKey, TRightKey>>
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperatorEnumerator.cs (1)
32internal abstract class InlinedAggregationOperatorEnumerator<TIntermediate> : QueryOperatorEnumerator<TIntermediate, int>
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (2)
207private sealed class OrderablePartitionerEnumerator : QueryOperatorEnumerator<TElement, int> 242private sealed class PartitionerEnumerator : QueryOperatorEnumerator<TElement, int>
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
149private sealed class AnyAllSearchOperatorEnumerator<TKey> : QueryOperatorEnumerator<bool, int>
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
127private sealed class ContainsSearchOperatorEnumerator<TKey> : QueryOperatorEnumerator<bool, int>
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
103private sealed class DefaultIfEmptyQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, TKey>
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
119private sealed class DistinctQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, int> 191private sealed class OrderedDistinctQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, TKey>
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
167private sealed class ElementAtQueryOperatorEnumerator : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
121private sealed class FirstQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
124private sealed class ForAllEnumerator<TKey> : QueryOperatorEnumerator<TInput, int>
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
222QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TOrderKey> 423QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TOrderKey>
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
134private sealed class IndexedSelectQueryOperatorEnumerator : QueryOperatorEnumerator<TOutput, int>
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
139private sealed class IndexedWhereQueryOperatorEnumerator : QueryOperatorEnumerator<TInputOutput, int>
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
117private sealed class LastQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
104private sealed class ReverseQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, TKey>
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
233private sealed class IndexedSelectManyQueryOperatorEnumerator : QueryOperatorEnumerator<TOutput, Pair<int, int>> 362private sealed class SelectManyQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TOutput, Pair<TLeftKey, int>>
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
93private sealed class SelectQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TOutput, TKey>
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
96private sealed class SingleQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
168internal sealed class SortQueryOperatorEnumerator<TInputOutput, TKey, TSortKey> : QueryOperatorEnumerator<TInputOutput, TSortKey>
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
151private sealed class TakeOrSkipQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TResult, TKey>
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
205private sealed class TakeOrSkipWhileQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TResult, TKey>
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
102private sealed class WhereQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, TKey>
291 references to QueryOperatorEnumerator
System.Linq.Parallel (291)
System\Linq\Parallel\Enumerables\IParallelPartitionable.cs (1)
20QueryOperatorEnumerator<T, int>[] GetPartitions(int partitionCount);
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (3)
39public QueryOperatorEnumerator<int, int>[] GetPartitions(int partitionCount) 47QueryOperatorEnumerator<int, int>[] partitions = new QueryOperatorEnumerator<int, int>[partitionCount];
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (3)
43public QueryOperatorEnumerator<TResult, int>[] GetPartitions(int partitionCount) 51QueryOperatorEnumerator<TResult, int>[] partitions = new QueryOperatorEnumerator<TResult, int>[partitionCount];
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)
34private readonly QueryOperatorEnumerator<TInputOutput, TIgnoreKey> _source; // The immediate source of data. 65QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, int partitionCount, int partitionIndex,
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
35private readonly QueryOperatorEnumerator<TInputOutput, TOrderKey> _source; // The immediate source of data. 67QueryOperatorEnumerator<TInputOutput, TOrderKey> source, int partitionCount, int partitionIndex,
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
87QueryOperatorEnumerator<T, int>[] partitions = new QueryOperatorEnumerator<T, int>[partitionCount]; 159private static QueryOperatorEnumerator<T, int>[] MakePartitions(IEnumerator<T> source, int partitionCount) 166QueryOperatorEnumerator<T, int>[] partitions = new QueryOperatorEnumerator<T, int>[partitionCount];
System\Linq\Parallel\Partitioning\PartitionedStream.cs (3)
34protected QueryOperatorEnumerator<TElement, TKey>[] _partitions; // Partitions exposed by this object. 41_partitions = new QueryOperatorEnumerator<TElement, TKey>[partitionCount]; 53internal QueryOperatorEnumerator<TElement, TKey> this[int index]
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (2)
227private readonly QueryOperatorEnumerator<TInput, TKey> _source; // The source data. 238internal AssociativeAggregationOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source,
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (4)
160private readonly QueryOperatorEnumerator<TSource, TLeftKey> _firstSource; // The first data source to enumerate. 161private readonly QueryOperatorEnumerator<TSource, TRightKey> _secondSource; // The second data source to enumerate. 169QueryOperatorEnumerator<TSource, TLeftKey> firstSource, 170QueryOperatorEnumerator<TSource, TRightKey> secondSource)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (9)
101outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TLeftKey>)(object) 139private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> _leftSource; // Left data source. 140private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> _rightSource; // Right data source. 151QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 152QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource, 229private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> _leftSource; // Left data source. 230private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> _rightSource; // Right data source. 243QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 244QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource,
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)
219private readonly QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> _dataSource; // data source. For building. 222internal GroupJoinHashLookupBuilder(QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> dataSource, IEqualityComparer<THashKey>? keyComparer) 305private readonly QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> _dataSource; // data source. For building. 310QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> dataSource,
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (3)
41private readonly QueryOperatorEnumerator<Pair<TLeftInput, THashKey>, TLeftKey> _leftSource; // Left (outer) data source. For probing. 63QueryOperatorEnumerator<Pair<TLeftInput, THashKey>, TLeftKey> leftSource, 237QueryOperatorEnumerator<Pair<TBaseElement, THashKey>, TBaseOrderKey> dataSource,
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (9)
102outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TLeftKey>)(object) 128private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> _leftSource; // Left data source. 129private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> _rightSource; // Right data source. 140QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 141QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource, 230private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> _leftSource; // Left data source. 231private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> _rightSource; // Right data source. 242QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 243QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource,
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (2)
196private readonly QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> _dataSource; // data source. For building. 199internal JoinHashLookupBuilder(QueryOperatorEnumerator<Pair<TElement, THashKey>, TOrderKey> dataSource, IEqualityComparer<THashKey>? keyComparer)
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (8)
185private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey>? _leftSource; // Left data source. 186private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey>? _rightSource; // Right data source. 197QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 198QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightSource, 294private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> _leftSource; // Left data source. 295private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> _rightSource; // Right data source. 310QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 311QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightSource,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (5)
65protected override QueryOperatorEnumerator<int, int> CreateEnumerator<TKey>( 66int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object? sharedData, 79private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The source data. 85internal CountAggregationOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source, int partitionIndex, 103QueryOperatorEnumerator<TSource, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (5)
73protected override QueryOperatorEnumerator<Pair<decimal, long>, int> CreateEnumerator<TKey>( 74int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object? sharedData, CancellationToken cancellationToken) 86private readonly QueryOperatorEnumerator<decimal, TKey> _source; // The source data. 92internal DecimalAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, 111QueryOperatorEnumerator<decimal, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (5)
90protected override QueryOperatorEnumerator<decimal, int> CreateEnumerator<TKey>( 91int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object? sharedData, CancellationToken cancellationToken) 103private readonly QueryOperatorEnumerator<decimal, TKey> _source; // The source data. 110internal DecimalMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, int sign, 127QueryOperatorEnumerator<decimal, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<decimal, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object? sharedData, CancellationToken cancellationToken) 73private readonly QueryOperatorEnumerator<decimal, TKey> _source; // The source data. 79internal DecimalSumAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, 97QueryOperatorEnumerator<decimal, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (5)
73protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 74int index, int count, QueryOperatorEnumerator<double, TKey> source, object? sharedData, 87private readonly QueryOperatorEnumerator<double, TKey> _source; // The source data. 93internal DoubleAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, 112QueryOperatorEnumerator<double, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (5)
96protected override QueryOperatorEnumerator<double, int> CreateEnumerator<TKey>( 97int index, int count, QueryOperatorEnumerator<double, TKey> source, object? sharedData, 110private readonly QueryOperatorEnumerator<double, TKey> _source; // The source data. 117internal DoubleMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, int sign, 134QueryOperatorEnumerator<double, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<double, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<double, TKey> source, object? sharedData, CancellationToken cancellationToken) 73private readonly QueryOperatorEnumerator<double, TKey> _source; // The source data. 79internal DoubleSumAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, 97QueryOperatorEnumerator<double, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (5)
73protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 74int index, int count, QueryOperatorEnumerator<float, TKey> source, object? sharedData, 87private readonly QueryOperatorEnumerator<float, TKey> _source; // The source data. 93internal FloatAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, 112QueryOperatorEnumerator<float, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (5)
95protected override QueryOperatorEnumerator<float, int> CreateEnumerator<TKey>( 96int index, int count, QueryOperatorEnumerator<float, TKey> source, object? sharedData, CancellationToken cancellationToken) 108private readonly QueryOperatorEnumerator<float, TKey> _source; // The source data. 115internal FloatMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, int sign, 132QueryOperatorEnumerator<float, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<double, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<float, TKey> source, object? sharedData, 74private readonly QueryOperatorEnumerator<float, TKey> _source; // The source data. 80internal FloatSumAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, 98QueryOperatorEnumerator<float, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (2)
134protected abstract QueryOperatorEnumerator<TIntermediate, int> CreateEnumerator<TKey>( 135int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object? sharedData, CancellationToken cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (5)
73protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 74int index, int count, QueryOperatorEnumerator<int, TKey> source, object? sharedData, CancellationToken cancellationToken) 86private readonly QueryOperatorEnumerator<int, TKey> _source; // The source data. 92internal IntAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, 111QueryOperatorEnumerator<int, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (5)
90protected override QueryOperatorEnumerator<int, int> CreateEnumerator<TKey>( 91int index, int count, QueryOperatorEnumerator<int, TKey> source, object? sharedData, CancellationToken cancellationToken) 103private readonly QueryOperatorEnumerator<int, TKey> _source; // The source data. 110internal IntMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, int sign, 127QueryOperatorEnumerator<int, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (5)
64protected override QueryOperatorEnumerator<int, int> CreateEnumerator<TKey>( 65int index, int count, QueryOperatorEnumerator<int, TKey> source, object? sharedData, CancellationToken cancellationToken) 77private readonly QueryOperatorEnumerator<int, TKey> _source; // The source data. 83internal IntSumAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, 101QueryOperatorEnumerator<int, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (5)
73protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 74int index, int count, QueryOperatorEnumerator<long, TKey> source, object? sharedData, CancellationToken cancellationToken) 86private readonly QueryOperatorEnumerator<long, TKey> _source; // The source data. 92internal LongAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, 111QueryOperatorEnumerator<long, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (5)
64protected override QueryOperatorEnumerator<long, int> CreateEnumerator<TKey>( 65int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object? sharedData, CancellationToken cancellationToken) 77private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The source data. 83internal LongCountAggregationOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source, int partitionIndex, 101QueryOperatorEnumerator<TSource, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (5)
90protected override QueryOperatorEnumerator<long, int> CreateEnumerator<TKey>( 91int index, int count, QueryOperatorEnumerator<long, TKey> source, object? sharedData, 104private readonly QueryOperatorEnumerator<long, TKey> _source; // The source data. 111internal LongMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, int sign, 128QueryOperatorEnumerator<long, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (5)
63protected override QueryOperatorEnumerator<long, int> CreateEnumerator<TKey>( 64int index, int count, QueryOperatorEnumerator<long, TKey> source, object? sharedData, CancellationToken cancellationToken) 76private readonly QueryOperatorEnumerator<long, TKey> _source; // The source data. 82internal LongSumAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, 100QueryOperatorEnumerator<long, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<Pair<decimal, long>, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object? sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<decimal?, TKey> _source; // The source data. 91internal NullableDecimalAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, 110QueryOperatorEnumerator<decimal?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (5)
89protected override QueryOperatorEnumerator<decimal?, int> CreateEnumerator<TKey>( 90int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object? sharedData, CancellationToken cancellationToken) 102private readonly QueryOperatorEnumerator<decimal?, TKey> _source; // The source data. 109internal NullableDecimalMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, int sign, 126QueryOperatorEnumerator<decimal?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<decimal?, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object? sharedData, CancellationToken cancellationToken) 73private readonly QueryOperatorEnumerator<decimal?, TKey> _source; // The source data. 79internal NullableDecimalSumAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, 97QueryOperatorEnumerator<decimal?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<double?, TKey> source, object? sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<double?, TKey> _source; // The source data. 91internal NullableDoubleAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, 110QueryOperatorEnumerator<double?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (5)
97protected override QueryOperatorEnumerator<double?, int> CreateEnumerator<TKey>( 98int index, int count, QueryOperatorEnumerator<double?, TKey> source, object? sharedData, CancellationToken cancellationToken) 110private readonly QueryOperatorEnumerator<double?, TKey> _source; // The source data. 117internal NullableDoubleMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, int sign, 134QueryOperatorEnumerator<double?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<double?, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<double?, TKey> source, object? sharedData, CancellationToken cancellationToken) 73private readonly QueryOperatorEnumerator<double?, TKey> _source; // The source data. 79internal NullableDoubleSumAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, 97QueryOperatorEnumerator<double?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<float?, TKey> source, object? sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<float?, TKey> _source; // The source data. 91internal NullableFloatAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, 110QueryOperatorEnumerator<float?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (5)
97protected override QueryOperatorEnumerator<float?, int> CreateEnumerator<TKey>( 98int index, int count, QueryOperatorEnumerator<float?, TKey> source, object? sharedData, CancellationToken cancellationToken) 110private readonly QueryOperatorEnumerator<float?, TKey> _source; // The source data. 117internal NullableFloatMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, int sign, 134QueryOperatorEnumerator<float?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (5)
60protected override QueryOperatorEnumerator<double?, int> CreateEnumerator<TKey>( 61int index, int count, QueryOperatorEnumerator<float?, TKey> source, object? sharedData, CancellationToken cancellationToken) 73private readonly QueryOperatorEnumerator<float?, TKey> _source; // The source data. 79internal NullableFloatSumAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, 97QueryOperatorEnumerator<float?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<int?, TKey> source, object? sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<int?, TKey> _source; // The source data. 91internal NullableIntAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, 110QueryOperatorEnumerator<int?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (5)
89protected override QueryOperatorEnumerator<int?, int> CreateEnumerator<TKey>( 90int index, int count, QueryOperatorEnumerator<int?, TKey> source, object? sharedData, CancellationToken cancellationToken) 102private readonly QueryOperatorEnumerator<int?, TKey> _source; // The source data. 109internal NullableIntMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, int sign, 126QueryOperatorEnumerator<int?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (5)
63protected override QueryOperatorEnumerator<int?, int> CreateEnumerator<TKey>( 64int index, int count, QueryOperatorEnumerator<int?, TKey> source, object? sharedData, CancellationToken cancellationToken) 76private readonly QueryOperatorEnumerator<int?, TKey> _source; // The source data. 82internal NullableIntSumAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, 100QueryOperatorEnumerator<int?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<long?, TKey> source, object? sharedData, 86private readonly QueryOperatorEnumerator<long?, TKey> _source; // The source data. 92internal NullableLongAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, 111QueryOperatorEnumerator<long?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (5)
89protected override QueryOperatorEnumerator<long?, int> CreateEnumerator<TKey>( 90int index, int count, QueryOperatorEnumerator<long?, TKey> source, object? sharedData, 103private readonly QueryOperatorEnumerator<long?, TKey> _source; // The source data. 110internal NullableLongMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, int sign, 127QueryOperatorEnumerator<long?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (5)
63protected override QueryOperatorEnumerator<long?, int> CreateEnumerator<TKey>( 64int index, int count, QueryOperatorEnumerator<long?, TKey> source, object? sharedData, 77private readonly QueryOperatorEnumerator<long?, TKey> _source; // The source data. 83internal NullableLongSumAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, 101QueryOperatorEnumerator<long?, TKey> source = _source;
System\Linq\Parallel\QueryOperators\QueryOperatorEnumerator.cs (2)
55private QueryOperatorEnumerator<TElement, TKey> _operatorEnumerator; 58internal QueryOperatorClassicEnumerator(QueryOperatorEnumerator<TElement, TKey> operatorEnumerator)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (2)
151private readonly QueryOperatorEnumerator<TInput, TKey> _source; // The source data. 162internal AnyAllSearchOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, bool qualification,
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (2)
129private readonly QueryOperatorEnumerator<TInput, TKey> _source; // The source data. 140internal ContainsSearchOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, TInput searchValue,
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (2)
105private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The data source to enumerate. 122QueryOperatorEnumerator<TSource, TKey> source, TSource defaultValue, int partitionIndex, int partitionCount,
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (5)
95outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TKey>)(object) 121private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> _source; // The data source. 131QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> source, IEqualityComparer<TInputOutput>? comparer, 193private readonly QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> _source; // The data source. 206QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)
169private readonly QueryOperatorEnumerator<TSource, int> _source; // The source data. 178internal ElementAtQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, int> source,
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (2)
123private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The data source to enumerate. 139QueryOperatorEnumerator<TSource, TKey> source, Func<TSource, bool>? predicate,
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (2)
126private readonly QueryOperatorEnumerator<TInput, TKey> _source; // The data source. 134internal ForAllEnumerator(QueryOperatorEnumerator<TInput, TKey> source, Action<TInput> elementAction, CancellationToken cancellationToken)
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (10)
119outputStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)enumerator; 158outputStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)enumerator; 224protected readonly QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> _source; // The data source to enumerate. 240QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 310QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 370QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 425protected readonly QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> _source; // The data source to enumerate. 442protected OrderedGroupByQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 538internal OrderedGroupByIdentityQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 611internal OrderedGroupByElementSelectorQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source,
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (2)
136private readonly QueryOperatorEnumerator<TInput, int> _source; // The data source to enumerate. 143internal IndexedSelectQueryOperatorEnumerator(QueryOperatorEnumerator<TInput, int> source, Func<TInput, int, TOutput> selector)
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (2)
141private readonly QueryOperatorEnumerator<TInputOutput, int> _source; // The data source to enumerate. 149internal IndexedWhereQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, int> source, Func<TInputOutput, int, bool> predicate,
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (2)
119private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The data source to enumerate. 135QueryOperatorEnumerator<TSource, TKey> source, Func<TSource, bool>? predicate,
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
106private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The data source to reverse. 115internal ReverseQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)
235private readonly QueryOperatorEnumerator<TLeftInput, int> _leftSource; // The left data source to enumerate. 257internal IndexedSelectManyQueryOperatorEnumerator(QueryOperatorEnumerator<TLeftInput, int> leftSource, 364private readonly QueryOperatorEnumerator<TLeftInput, TLeftKey> _leftSource; // The left data source to enumerate. 386internal SelectManyQueryOperatorEnumerator(QueryOperatorEnumerator<TLeftInput, TLeftKey> leftSource,
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (2)
95private readonly QueryOperatorEnumerator<TInput, TKey> _source; // The data source to enumerate. 102internal SelectQueryOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, Func<TInput, TOutput> selector)
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (2)
98private readonly QueryOperatorEnumerator<TSource, TKey> _source; // The data source to enumerate. 110internal SingleQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (2)
170private readonly QueryOperatorEnumerator<TInputOutput, TKey>? _source; // Data source to sort. 177internal SortQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (2)
153private readonly QueryOperatorEnumerator<TResult, TKey> _source; // The data source to enumerate. 171QueryOperatorEnumerator<TResult, TKey> source, bool take,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)
207private readonly QueryOperatorEnumerator<TResult, TKey> _source; // The data source to enumerate. 229QueryOperatorEnumerator<TResult, TKey> source, Func<TResult, bool>? predicate, Func<TResult, TKey, bool>? indexedPredicate, bool take,
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (2)
104private readonly QueryOperatorEnumerator<TInputOutput, TKey> _source; // The data source to enumerate. 113internal WhereQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, TKey> source, Func<TInputOutput, bool> predicate,
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)
27private readonly QueryOperatorEnumerator<TOutput, TKey> _partition; // The source partition. 56QueryOperatorEnumerator<TOutput, TKey> partition, 97var partition = _partition;
System\Linq\Parallel\Scheduling\SpoolingTask.cs (8)
184private readonly QueryOperatorEnumerator<TInputOutput, TIgnoreKey> _source; 204QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, SynchronousChannel<TInputOutput> destination) 224QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source = _source; 273private readonly QueryOperatorEnumerator<TInputOutput, TIgnoreKey> _source; 293QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, AsynchronousChannel<TInputOutput> destination) 313QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source = _source; 361private readonly QueryOperatorEnumerator<TInputOutput, TIgnoreKey> _source; 377QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source)
System\Linq\Parallel\Utils\ExceptionAggregator.cs (1)
58internal static IEnumerable<TElement> WrapQueryEnumerator<TElement, TIgnoreKey>(QueryOperatorEnumerator<TElement, TIgnoreKey> source,
System\Linq\Parallel\Utils\ExchangeUtilities.cs (2)
41QueryOperatorEnumerator<T, int>[] enumerators = sourceAsPartitionable.GetPartitions(partitionCount); 56QueryOperatorEnumerator<T, int> currentEnumerator = enumerators[i];
System\Linq\Parallel\Utils\Sorting.cs (2)
37private readonly QueryOperatorEnumerator<TInputOutput, TKey> _source; // The data source from which to pull data. 57private SortHelper(QueryOperatorEnumerator<TInputOutput, TKey> source, int partitionCount, int partitionIndex,