Child

74 references to Child

System.Core (74)

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)

194QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);

System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (1)

125QueryResults<TSource> childQueryResults = Child.Open(settings, preferStriping);

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

102QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);

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

91QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);

System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (3)

46SetOrdinalIndexState(ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Correct)); 57QueryResults<TSource> childQueryResults = Child.Open(settings, preferStriping); 88return Child.AsSequentialQuery(token).DefaultIfEmpty(m_defaultValue);

System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)

53QueryResults<TInputOutput> childResults = Child.Open(settings, false); 193IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (5)

48OrdinalIndexState childIndexState = Child.OrdinalIndexState; 65QueryResults<TSource> childQueryResults = Child.Open(settings, false); 78intKeyStream = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream(); 137IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.ExternalCancellationToken); 143IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.ExternalCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (3)

45m_prematureMergeNeeded = Child.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing); 56QueryResults<TSource> childQueryResults = Child.Open(settings, false); 66ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings);

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

83QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping);

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)

77if (Child.OutputOrdered) 185QueryResults<TSource> childResults = Child.Open(settings, false); 195IEnumerable<TSource> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

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

65OrdinalIndexState childIndexState = Child.OrdinalIndexState; 88QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping); 102inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings); 188return Child.AsSequentialQuery(token).Select(m_selector);

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

64OrdinalIndexState childIndexState = Child.OrdinalIndexState; 83QueryResults<TInputOutput> childQueryResults = Child.Open(settings, preferStriping); 96ListQueryResults<TInputOutput> listResults = ExecuteAndCollectResults(inputStream, partitionCount, Child.OutputOrdered, preferStriping, settings); 124IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (3)

46m_prematureMergeNeeded = Child.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing); 56QueryResults<TSource> childQueryResults = Child.Open(settings, false); 67ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream();

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (4)

47if (Child.OrdinalIndexState == OrdinalIndexState.Indexible) 61Contract.Assert(Child.OrdinalIndexState != OrdinalIndexState.Indexible, "Don't take this code path if the child is indexible."); 81QueryResults<TSource> childQueryResults = Child.Open(settings, false); 91IEnumerable<TSource> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (7)

76m_outputOrdered = Child.OutputOrdered || indexedRightChildSelector != null; 83OrdinalIndexState childIndexState = Child.OrdinalIndexState; 192QueryResults<TLeftInput> childQueryResults = Child.Open(settings, preferStriping); 206return CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(m_rightChildSelector, m_resultSelector); 208return (IEnumerable<TOutput>)(object)(CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(m_rightChildSelector)); 215return CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(m_indexedRightChildSelector, m_resultSelector); 218return (IEnumerable<TOutput>)(object)(CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token).SelectMany(m_indexedRightChildSelector));

System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (3)

50SetOrdinalIndexState(Child.OrdinalIndexState); 74QueryResults<TInput> childQueryResults = Child.Open(settings, preferStriping); 80return Child.AsSequentialQuery(token).Select(m_selector);

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

55QueryResults<TSource> childQueryResults = Child.Open(settings, false);

System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (3)

79return new SortQueryOperator<TInputOutput, Pair<TSortKey, TKey2>>(Child, pairKeySelector, pairComparer, false); 107QueryResults<TInputOutput> childQueryResults = Child.Open(settings, false); 133IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

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

68OrdinalIndexState indexState = Child.OrdinalIndexState; 93Contract.Assert(Child.OrdinalIndexState != OrdinalIndexState.Indexible, "Don't take this code path if the child is indexible."); 99inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 134QueryResults<TResult> childQueryResults = Child.Open(settings, true); 320return Child.AsSequentialQuery(token).Take(m_count); 323IEnumerable<TResult> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

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

94OrdinalIndexState childIndexState = Child.OrdinalIndexState; 122ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 164QueryResults<TResult> childQueryResults = Child.Open(settings, true); 178return Child.AsSequentialQuery(token).TakeWhile(m_indexedPredicate); 181return Child.AsSequentialQuery(token).TakeWhile(m_predicate); 186IEnumerable<TResult> wrappedIndexedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token); 190IEnumerable<TResult> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (3)

49ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Increasing)); 76QueryResults<TInputOutput> childQueryResults = Child.Open(settings, preferStriping); 88IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.Wrap(Child.AsSequentialQuery(token), token);

System\Linq\ParallelEnumerable.cs (8)

5455IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5497IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5539IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5584IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5633IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5675IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5717IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken); 5758IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);