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