7 overrides of GivePartitionedStream
System.Linq.Parallel (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
202
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
103
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
31
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<T> recipient)
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
128
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TElement> recipient)
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
129
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TElement> recipient)
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
139
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TInputOutput> recipient)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
108
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
8 references to GivePartitionedStream
System.Linq.Parallel (8)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
96
leftChildResults.
GivePartitionedStream
(merger);
107
rightChildResults.
GivePartitionedStream
(merger);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
127
_leftChildQueryResults.
GivePartitionedStream
(new LeftChildResultsRecipient(recipient, this, _preferStriping, _settings));
157
_results._rightChildQueryResults.
GivePartitionedStream
(rightChildRecipient);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
159
queryResults.
GivePartitionedStream
(merger); // hook up the data flow between the operator-executors, starting from the merger.
237
results.
GivePartitionedStream
(merger);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
141
_childQueryResults.
GivePartitionedStream
(new ChildResultsRecipient(recipient, _op, _settings));
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
130
_childQueryResults.
GivePartitionedStream
(new ChildResultsRecipient(recipient, _op, _preferStriping, _settings));