12 references to GetPartitionedStream
System.Core (12)
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
37
PartitionedStream<T, int> partitionedStream =
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (2)
89
PartitionedStream<TSource, int> leftStreamInc = leftStreamResults.
GetPartitionedStream
();
108
PartitionedStream<TSource, int> rightStreamInc = rightStreamResults.
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
78
intKeyStream = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings).
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
67
WrapHelper<int>(listResults.
GetPartitionedStream
(), recipient, settings);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
103
inputStreamInt = listResults.
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
97
inputStreamInt = listResults.
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
67
ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
121
inputStreamInt = listResults.
GetPartitionedStream
();
137
.
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
100
PartitionedStream<TResult, int> inputIntStream = results.
GetPartitionedStream
();
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
123
PartitionedStream<TResult, int> listInputStream = results.
GetPartitionedStream
();