7 overrides of GivePartitionedStream
System.Core (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
203
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
107
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
35
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<T> recipient)
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
134
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TElement> recipient)
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
136
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TElement> recipient)
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
170
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TInputOutput> recipient)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
113
internal override void
GivePartitionedStream
(IPartitionedStreamRecipient<TOutput> recipient)
8 references to GivePartitionedStream
System.Core (8)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
99
leftChildResults.
GivePartitionedStream
(merger);
109
rightChildResults.
GivePartitionedStream
(merger);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
128
m_leftChildQueryResults.
GivePartitionedStream
(new LeftChildResultsRecipient(recipient, this, m_preferStriping, m_settings));
158
m_results.m_rightChildQueryResults.
GivePartitionedStream
(rightChildRecipient);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
168
queryResults.
GivePartitionedStream
(merger); // hook up the data flow between the operator-executors, starting from the merger.
233
results.
GivePartitionedStream
(merger);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
172
m_childQueryResults.
GivePartitionedStream
(new ChildResultsRecipient(recipient, m_op, m_settings));
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
134
m_childQueryResults.
GivePartitionedStream
(new ChildResultsRecipient(recipient, m_op, m_preferStriping, m_settings));