IPartitionedStreamRecipient

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)

182PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient,

System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (3)

78IPartitionedStreamRecipient<TSource> outputRecipient, bool preferStriping, QuerySettings settings) 97IPartitionedStreamRecipient<TSource> outputRecipient, QuerySettings settings, bool preferStriping) 116IPartitionedStreamRecipient<TSource> outputRecipient)

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

54IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 81IPartitionedStreamRecipient<TInputOutput> outputRecipient, CancellationToken cancellationToken)

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

73IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings) 99IPartitionedStreamRecipient<TOutput> outputRecipient, int partitionCount, CancellationToken cancellationToken) 138IComparer<TRightKey>? rightKeyComparer, IPartitionedStreamRecipient<TOutput> outputRecipient, 172IPartitionedStreamRecipient<TOutput> outputRecipient, int partitionCount, CancellationToken cancellationToken)

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

56IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 83IPartitionedStreamRecipient<TInputOutput> outputRecipient, CancellationToken cancellationToken)

System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (3)

76IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings) 113IPartitionedStreamRecipient<TOutput> outputRecipient, CancellationToken cancellationToken) 138IPartitionedStreamRecipient<TOutput> outputRecipient, CancellationToken cancellationToken)

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

58IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 91IPartitionedStreamRecipient<TInputOutput> outputRecipient, int partitionCount, CancellationToken cancellationToken) 120IPartitionedStreamRecipient<TInputOutput> outputRecipient, int partitionCount,

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

202internal override void GivePartitionedStream(IPartitionedStreamRecipient<TOutput> recipient)

System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (6)

76IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings); 103internal override void GivePartitionedStream(IPartitionedStreamRecipient<TOutput> recipient) 139private readonly IPartitionedStreamRecipient<TOutput> _outputRecipient; 144internal LeftChildResultsRecipient(IPartitionedStreamRecipient<TOutput> outputRecipient, BinaryQueryOperatorResults results, 172private readonly IPartitionedStreamRecipient<TOutput> _outputRecipient; 179IPartitionedStreamRecipient<TOutput> outputRecipient, BinaryQueryOperator<TLeftInput, TRightInput, TOutput> op,

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

120PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient,

System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)

31internal override void GivePartitionedStream(IPartitionedStreamRecipient<T> recipient)

System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)

128internal override void GivePartitionedStream(IPartitionedStreamRecipient<TElement> recipient)

System\Linq\Parallel\QueryOperators\QueryResults.cs (1)

40internal abstract void GivePartitionedStream(IPartitionedStreamRecipient<T> recipient);

System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)

129internal override void GivePartitionedStream(IPartitionedStreamRecipient<TElement> recipient)

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

103PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<bool> recipient, bool preferStriping, QuerySettings settings)

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

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<bool> recipient, bool preferStriping, QuerySettings settings)

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

58PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings)

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

54PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 80IPartitionedStreamRecipient<TInputOutput> recipient, CancellationToken cancellationToken)

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

66PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings)

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

57PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 72PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings)

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

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TInput> recipient, bool preferStriping, QuerySettings settings)

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

69PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 100IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 138IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient,

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

89PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings)

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

84PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings)

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

57PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 72private void WrapHelper<TKey>(PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings)

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

54PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings)

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

104PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 148PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 166PartitionedStream<TLeftInput, int> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings)

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

50PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings)

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

56PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings)

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

84PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 139internal override void GivePartitionedStream(IPartitionedStreamRecipient<TInputOutput> recipient) 146private readonly IPartitionedStreamRecipient<TInputOutput> _outputRecipient; 150internal ChildResultsRecipient(IPartitionedStreamRecipient<TInputOutput> outputRecipient, SortQueryOperator<TInputOutput, TSortKey> op, QuerySettings settings)

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

87PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 105private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings)

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

113PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 127private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings)

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

51PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings)

System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (4)

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, 108internal override void GivePartitionedStream(IPartitionedStreamRecipient<TOutput> recipient) 143private readonly IPartitionedStreamRecipient<TOutput> _outputRecipient; 149IPartitionedStreamRecipient<TOutput> outputRecipient, UnaryQueryOperator<TInput, TOutput> op, bool preferStriping, QuerySettings settings)