System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (8)
44_outputOrdered = LeftChild.OutputOrdered || RightChild.OutputOrdered;
46_prematureMergeLeft = LeftChild.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing);
49if ((LeftChild.OrdinalIndexState == OrdinalIndexState.Indexable)
58ExchangeUtilities.Worse(LeftChild.OrdinalIndexState, RightChild.OrdinalIndexState)));
70QueryResults<TSource> leftChildResults = LeftChild.Open(settings, preferStriping);
84ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings);
103ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings);
140return LeftChild.AsSequentialQuery(token).Concat(RightChild.AsSequentialQuery(token));