WrapHelper< TLeftKey, TRightKey >()

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

inlineprivate

Definition at line 130 of file ConcatQueryOperator.cs.

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

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