System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (8)
48m_outputOrdered = LeftChild.OutputOrdered || RightChild.OutputOrdered;
50m_prematureMergeLeft = LeftChild.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing);
53if ((LeftChild.OrdinalIndexState == OrdinalIndexState.Indexible)
62ExchangeUtilities.Worse(LeftChild.OrdinalIndexState, RightChild.OrdinalIndexState)));
74QueryResults<TSource> leftChildResults = LeftChild.Open(settings, preferStriping);
88ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings);
107ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings);
144return LeftChild.AsSequentialQuery(token).Concat(RightChild.AsSequentialQuery(token));