13 references to GetPartitionedStream
System.Linq.Parallel (13)
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (2)
85PartitionedStream<TSource, int> leftStreamInc = leftStreamResults.GetPartitionedStream(); 104PartitionedStream<TSource, int> rightStreamInc = rightStreamResults.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
86.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
33PartitionedStream<T, int> partitionedStream = GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
74intKeyStream = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
63WrapHelper<int>(listResults.GetPartitionedStream(), recipient, settings);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
99inputStreamInt = listResults.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
93inputStreamInt = listResults.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
63ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
117inputStreamInt = listResults.GetPartitionedStream(); 133.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
96PartitionedStream<TResult, int> inputIntStream = results.GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
118PartitionedStream<TResult, int> listInputStream = results.GetPartitionedStream();