IPartitionedStreamRecipient

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

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

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

58IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 85IPartitionedStreamRecipient<TInputOutput> outputRecipient, CancellationToken cancellationToken)

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

78IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings) 104IPartitionedStreamRecipient<TOutput> outputRecipient, int partitionCount, CancellationToken cancellationToken)

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

60IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 87IPartitionedStreamRecipient<TInputOutput> outputRecipient, CancellationToken cancellationToken)

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

81IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings) 106IPartitionedStreamRecipient<TOutput> outputRecipient, CancellationToken cancellationToken)

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

62IPartitionedStreamRecipient<TInputOutput> outputRecipient, bool preferStriping, QuerySettings settings) 95IPartitionedStreamRecipient<TInputOutput> outputRecipient, int partitionCount, CancellationToken cancellationToken) 124IPartitionedStreamRecipient<TInputOutput> outputRecipient, int partitionCount,

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

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

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

80IPartitionedStreamRecipient<TOutput> outputRecipient, bool preferStriping, QuerySettings settings); 107internal override void GivePartitionedStream(IPartitionedStreamRecipient<TOutput> recipient) 140IPartitionedStreamRecipient<TOutput> m_outputRecipient; 145internal LeftChildResultsRecipient(IPartitionedStreamRecipient<TOutput> outputRecipient, BinaryQueryOperatorResults results, 173IPartitionedStreamRecipient<TOutput> m_outputRecipient; 180IPartitionedStreamRecipient<TOutput> outputRecipient, BinaryQueryOperator<TLeftInput, TRightInput, TOutput> op,

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

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

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

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

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

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

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

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

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

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

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

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

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

82IPartitionedStreamRecipient<TSource> outputRecipient, bool preferStriping, QuerySettings settings) 101IPartitionedStreamRecipient<TSource> outputRecipient, QuerySettings settings, bool preferStriping) 120IPartitionedStreamRecipient<TSource> outputRecipient)

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

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

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

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

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

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

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

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

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

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

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

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

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

73PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 104IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 143IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient,

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

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

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

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

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

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

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

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

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

108PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 152PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 170PartitionedStream<TLeftInput, int> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings)

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

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

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

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

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

113PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 170internal override void GivePartitionedStream(IPartitionedStreamRecipient<TInputOutput> recipient) 177IPartitionedStreamRecipient<TInputOutput> m_outputRecipient; 181internal ChildResultsRecipient(IPartitionedStreamRecipient<TInputOutput> outputRecipient, SortQueryOperator<TInputOutput, TSortKey> op, QuerySettings settings)

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

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

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

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

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

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

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

89PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, 113internal override void GivePartitionedStream(IPartitionedStreamRecipient<TOutput> recipient) 147IPartitionedStreamRecipient<TOutput> m_outputRecipient; 153IPartitionedStreamRecipient<TOutput> outputRecipient, UnaryQueryOperator<TInput, TOutput> op, bool preferStriping, QuerySettings settings)