WrapPartitionedStreamFixedLeftType< TLeftKey, TRightKey >()

void System.Linq.Parallel.UnionQueryOperator< TInputOutput >.WrapPartitionedStreamFixedLeftType< TLeftKey, TRightKey > ( PartitionedStream< Pair< TInputOutput, NoKeyMemoizationRequired >, TLeftKey > leftHashStream, PartitionedStream< TInputOutput, TRightKey > rightStream, IPartitionedStreamRecipient< TInputOutput > outputRecipient, int partitionCount, CancellationToken cancellationToken )

inlineprivate

Definition at line 214 of file UnionQueryOperator.cs.

    {
        if (base.RightChild.OutputOrdered)
        {
            PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightHashStream = ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TRightKey>(rightStream, null, null, _comparer, cancellationToken);
            WrapPartitionedStreamFixedBothTypes(leftHashStream, rightHashStream, outputRecipient, partitionCount, cancellationToken);
        }
        else
        {
            PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream2 = ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(rightStream, null, null, _comparer, cancellationToken);
            WrapPartitionedStreamFixedBothTypes(leftHashStream, rightHashStream2, outputRecipient, partitionCount, cancellationToken);
        }
    }

References System.Linq.Parallel.UnionQueryOperator< TInputOutput >._comparer, and System.cancellationToken.