4 instantiations of ListQueryResults
System.Linq.Parallel (4)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
98
leftChildResults = new
ListQueryResults
<TLeftInput>(
109
rightChildResults = new
ListQueryResults
<TRightInput>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
292
return new
ListQueryResults
<TOutput>(executor.GetResultsAsArray()!, partitionCount, useStriping);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
63
return new
ListQueryResults
<TElement>(dataAsList, settings.DegreeOfParallelism.GetValueOrDefault(), preferStriping);
9 references to ListQueryResults
System.Linq.Parallel (9)
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (2)
83
ListQueryResults
<TSource> leftStreamResults =
102
ListQueryResults
<TSource> rightStreamResults =
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
279
internal static
ListQueryResults
<TOutput> ExecuteAndCollectResults<TKey>(
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
62
ListQueryResults
<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
97
ListQueryResults
<TInput> listResults = QueryOperator<TInput>.ExecuteAndCollectResults(
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
92
ListQueryResults
<TInputOutput> listResults = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (1)
115
ListQueryResults
<TLeftInput> listResults =
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
94
ListQueryResults
<TResult> results = ExecuteAndCollectResults(
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
117
ListQueryResults
<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);