Pair

System\Linq\Parallel\Enumerables\AggregationMinMaxHelpers.cs (3)

33new AssociativeAggregationOperator<T, Pair<bool, T>, T>(source, new Pair<bool, T>(false, default!), null, 77return new Pair<bool, T>(true, element); 102return new Pair<bool, T>(true, element.Second);

System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)

119currentElement = new Pair<TInputOutput, THashKey>( 244buffer.Add(new Pair<TInputOutput, THashKey>(element, elementHashKey));

System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)

116currentElement = new Pair<TInputOutput, THashKey>( 254buffer.Add(new Pair<TInputOutput, THashKey>(element, elementHashKey));

System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)

306leftLookup[wrappedLeftElement] = new Pair<TInputOutput, TLeftKey>(leftElement.First, leftKey);

System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)

292return new Pair<IEnumerable<TElement>, int>(baseValue, OrderKey); 398return new Pair<IEnumerable<TElement>, Pair<bool, TOrderKey>>(baseValue._grouping, Wrap(baseValue._orderKey)); 403return new Pair<bool, TOrderKey>(true, orderKey); 455return new Pair<IEnumerable<TElement>, TOrderKey>(ParallelEnumerable.Empty<TElement>(), EmptyValueKey);

System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (2)

222return new Pair<TLeftKey, TRightKey>(leftKey, rightKey); 385return new Pair<TElement, TOrderKey>(value, orderKey);

System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)

290_hashLookup[wrappedLeftElem] = new Pair<TInputOutput, TLeftKey>(leftElement.First, leftKey);

System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)

360union[wrappedElem] = new Pair<TInputOutput, ConcatKey<TLeftKey, TRightKey>>(elem.First, key); 377union[wrappedElem] = new Pair<TInputOutput, ConcatKey<TLeftKey, TRightKey>>(elem.First, key);

System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)

131currentElement = new Pair<decimal, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)

132currentElement = new Pair<double, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)

132currentElement = new Pair<double, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)

131currentElement = new Pair<long, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)

131currentElement = new Pair<long, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)

129currentElement = new Pair<decimal, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)

129currentElement = new Pair<double, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)

130currentElement = new Pair<double, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)

130currentElement = new Pair<long, long>(sum, count);

System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)

130currentElement = new Pair<long, long>(sum, count);

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (1)

776_values.Add(new Pair<TOrderKey, TElement>(orderKey, value));

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)

143_buffer.Add(new Pair<TSource, TKey>(current, key));

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)

336currentKey = new Pair<int, int>(_mutables._currentLeftSourceIndex, _mutables._currentRightSourceIndex); 465currentKey = new Pair<TLeftKey, int>(_mutables._currentLeftKey, _mutables._currentRightSourceIndex);

System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)

66(TInputOutput elem) => new Pair<TSortKey, TKey2>(_keySelector(elem), key2Selector(elem));

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)

214buffer.Add(new Pair<TResult, TKey>(current, index));

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)

277buffer.Add(new Pair<TResult, TKey>(current, key));

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)

106chunk[lastChunkSize] = new Pair<TKey, TOutput>(key, element);