Receive

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

194recipient.Receive(outputStream);

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

130outputRecipient.Receive(outputStream);

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

106outputRecipient.Receive(outputStream);

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

183outputRecipient.Receive(outputStream);

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

107outputRecipient.Receive(outputStream);

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

153outputRecipient.Receive(outputStream);

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

138outputRecipient.Receive(outputStream); 151outputRecipient.Receive(outputStream);

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

205recipient.Receive(partitionedStream);

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

115recipient.Receive<int>(result); 122recipient.Receive<int>(result);

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

131recipient.Receive(outputStream);

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

34recipient.Receive<int>(partitionedStream);

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

199recipient.Receive<int>(partitions);

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

135recipient.Receive<int>(partitionedStream);

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

118recipient.Receive(outputStream);

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

97recipient.Receive(outputStream);

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

77recipient.Receive(outputStream);

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

100recipient.Receive(outputStream);

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

93recipient.Receive(outputStream);

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

92recipient.Receive(outputStream);

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

95recipient.Receive(outputStream);

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

128recipient.Receive(outputStream); 168recipient.Receive(outputStream);

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

116recipient.Receive(outputStream);

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

110recipient.Receive(outputStream);

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

90recipient.Receive(outputStream);

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

66recipient.Receive(outputStream);

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

158recipient.Receive(outputStream); 177recipient.Receive(outputStream);

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

59recipient.Receive(outputStream);

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

68recipient.Receive(outputStream);

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

95recipient.Receive<TSortKey>(outputStream);

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

123recipient.Receive(outputStream);

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

149recipient.Receive(partitionedStream);

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

61recipient.Receive(outputStream);

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

119recipient.Receive<int>(result); 125recipient.Receive<int>(result);