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