ExecuteAndCollectResults

12 references to ExecuteAndCollectResults

System.Linq.Parallel (12)

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

84ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings); 103ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings);

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

85QueryOperator<TLeftInput>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, OutputOrdered, preferStriping, settings)

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)

62ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);

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

97ListQueryResults<TInput> listResults = QueryOperator<TInput>.ExecuteAndCollectResults(

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

92ListQueryResults<TInputOutput> listResults = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings);

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)

116QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings); 132QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings)

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

94ListQueryResults<TResult> results = ExecuteAndCollectResults(

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

117ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);