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

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

inline

Definition at line 199 of file UnionQueryOperator.cs.

    {
        int partitionCount = leftStream.PartitionCount;
        if (base.LeftChild.OutputOrdered)
        {
            PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream = ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>(leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken);
            WrapPartitionedStreamFixedLeftType(leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
        }
        else
        {
            PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> leftHashStream2 = ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>(leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken);
            WrapPartitionedStreamFixedLeftType(leftHashStream2, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
        }
    }

References System.Linq.Parallel.UnionQueryOperator< TInputOutput >._comparer, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.