5 implementations of Receive
System.Core (5)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
154
public void
Receive
<TLeftKey>(PartitionedStream<TLeftInput, TLeftKey> source)
190
public void
Receive
<TRightKey>(PartitionedStream<TRightInput, TRightKey> rightPartitionedStream)
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (1)
59
public void
Receive
<TKey>(PartitionedStream<TOutput, TKey> partitionedStream)
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
188
public void
Receive
<TKey>(PartitionedStream<TInputOutput, TKey> childPartitionedStream)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
161
public void
Receive
<TKey>(PartitionedStream<TInput, TKey> inputStream)
38 references to Receive
System.Core (38)
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
211
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
110
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
118
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
111
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
121
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
142
outputRecipient.
Receive
(outputStream);
155
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
206
recipient.
Receive
(partitionedStream);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
117
recipient.
Receive
<int>(result);
123
recipient.
Receive
<int>(result);
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (1)
142
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
38
recipient.
Receive
<int>(partitionedStream);
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
205
recipient.
Receive
<int>(partitions);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
141
recipient.
Receive
<int>(partitionedStream);
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
122
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (1)
134
outputRecipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
110
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
79
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
104
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
97
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
94
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
99
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
133
recipient.
Receive
(outputStream);
174
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
120
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
114
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
92
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
71
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
162
recipient.
Receive
(outputStream);
181
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
63
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
72
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
124
recipient.
Receive
<TSortKey>(outputStream);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
124
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
154
recipient.
Receive
(partitionedStream);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
65
recipient.
Receive
(outputStream);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
123
recipient.
Receive
<int>(result);
129
recipient.
Receive
<int>(result);