74 references to Child
System.Linq.Parallel (74)
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
177QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (1)
115QueryResults<TSource> childQueryResults = Child.Open(settings, preferStriping);
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
98QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
79QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (3)
42SetOrdinalIndexState(ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Correct)); 53QueryResults<TSource> childQueryResults = Child.Open(settings, preferStriping); 86return Child.AsSequentialQuery(token).DefaultIfEmpty(_defaultValue);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
49QueryResults<TInputOutput> childResults = Child.Open(settings, false); 187IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (5)
44OrdinalIndexState childIndexState = Child.OrdinalIndexState; 61QueryResults<TSource> childQueryResults = Child.Open(settings, false); 74intKeyStream = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream(); 134IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.ExternalCancellationToken); 140IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.ExternalCancellationToken);
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (3)
41_prematureMergeNeeded = Child.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing); 52QueryResults<TSource> childQueryResults = Child.Open(settings, false); 62ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
79QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)
73if (Child.OutputOrdered) 179QueryResults<TSource> childResults = Child.Open(settings, false); 189IEnumerable<TSource> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (4)
61OrdinalIndexState childIndexState = Child.OrdinalIndexState; 84QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping); 98inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings); 182return Child.AsSequentialQuery(token).Select(_selector);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (4)
60OrdinalIndexState childIndexState = Child.OrdinalIndexState; 79QueryResults<TInputOutput> childQueryResults = Child.Open(settings, preferStriping); 92ListQueryResults<TInputOutput> listResults = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings); 120IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (3)
42_prematureMergeNeeded = Child.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing); 52QueryResults<TSource> childQueryResults = Child.Open(settings, false); 63ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (4)
43if (Child.OrdinalIndexState == OrdinalIndexState.Indexable) 56Debug.Assert(Child.OrdinalIndexState != OrdinalIndexState.Indexable, "Don't take this code path if the child is indexable."); 76QueryResults<TSource> childQueryResults = Child.Open(settings, false); 86IEnumerable<TSource> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (7)
72_outputOrdered = Child.OutputOrdered || indexedRightChildSelector != null; 79OrdinalIndexState childIndexState = Child.OrdinalIndexState; 188QueryResults<TLeftInput> childQueryResults = Child.Open(settings, preferStriping); 202return CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(_rightChildSelector, _resultSelector); 204return (IEnumerable<TOutput>)CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(_rightChildSelector); 211return CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(_indexedRightChildSelector, _resultSelector); 214return (IEnumerable<TOutput>)CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(_indexedRightChildSelector);
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (3)
46SetOrdinalIndexState(Child.OrdinalIndexState); 70QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping); 76return Child.AsSequentialQuery(token).Select(_selector);
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
51QueryResults<TSource> childQueryResults = Child.Open(settings, false);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (3)
68return new SortQueryOperator<TInputOutput, Pair<TSortKey, TKey2>>(Child, pairKeySelector, pairComparer, false); 78QueryResults<TInputOutput> childQueryResults = Child.Open(settings, false); 104IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (6)
64OrdinalIndexState indexState = Child.OrdinalIndexState; 89Debug.Assert(Child.OrdinalIndexState != OrdinalIndexState.Indexable, "Don't take this code path if the child is indexable."); 95inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 133QueryResults<TResult> childQueryResults = Child.Open(settings, true); 321return Child.AsSequentialQuery(token).Take(_count); 324IEnumerable<TResult> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (7)
90OrdinalIndexState childIndexState = Child.OrdinalIndexState; 117ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 159QueryResults<TResult> childQueryResults = Child.Open(settings, true); 173return Child.AsSequentialQuery(token).TakeWhile(_indexedPredicate); 177return Child.AsSequentialQuery(token).TakeWhile(_predicate); 182IEnumerable<TResult> wrappedIndexedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token); 187IEnumerable<TResult> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (3)
45ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Increasing)); 72QueryResults<TInputOutput> childQueryResults = Child.Open(settings, preferStriping); 84IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);
System\Linq\ParallelEnumerable.cs (8)
5408IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5450IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5491IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5536IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5585IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5627IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5669IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5710IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);