WrapPartitionedStream< TLeftKey, TRightKey >() [2/2]

override void System.Linq.Parallel.ConcatQueryOperator< TSource >.WrapPartitionedStream< TLeftKey, TRightKey > ( PartitionedStream< TSource, TLeftKey > leftStream, PartitionedStream< TSource, TRightKey > rightStream, IPartitionedStreamRecipient< TSource > outputRecipient, bool preferStriping, QuerySettings settings )

inline

Definition at line 116 of file ConcatQueryOperator.cs.

    {
        if (_prematureMergeLeft)
        {
            ListQueryResults<TSource> listQueryResults = QueryOperator<TSource>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, base.LeftChild.OutputOrdered, preferStriping, settings);
            PartitionedStream<TSource, int> partitionedStream = listQueryResults.GetPartitionedStream();
            WrapHelper(partitionedStream, rightStream, outputRecipient, settings, preferStriping);
        }
        else
        {
            WrapHelper(leftStream, rightStream, outputRecipient, settings, preferStriping);
        }
    }

References System.Linq.Parallel.ConcatQueryOperator< TSource >._prematureMergeLeft.