WrapPartitionedStreamFixedBothTypes< TLeftKey, TRightKey >()

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

inlineprivate

Definition at line 228 of file UnionQueryOperator.cs.

    {
        if (base.LeftChild.OutputOrdered || base.RightChild.OutputOrdered)
        {
            IComparer<ConcatKey<TLeftKey, TRightKey>> keyComparer = ConcatKey<TLeftKey, TRightKey>.MakeComparer(leftHashStream.KeyComparer, rightHashStream.KeyComparer);
            PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>> partitionedStream = new PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>>(partitionCount, keyComparer, OrdinalIndexState.Shuffled);
            for (int i = 0; i < partitionCount; i++)
            {
                partitionedStream[i] = new OrderedUnionQueryOperatorEnumerator<TLeftKey, TRightKey>(leftHashStream[i], rightHashStream[i], base.LeftChild.OutputOrdered, base.RightChild.OutputOrdered, _comparer, keyComparer, cancellationToken);
            }
            outputRecipient.Receive(partitionedStream);
        }
        else
        {
            PartitionedStream<TInputOutput, int> partitionedStream2 = new PartitionedStream<TInputOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Shuffled);
            for (int j = 0; j < partitionCount; j++)
            {
                partitionedStream2[j] = new UnionQueryOperatorEnumerator<TLeftKey, TRightKey>(leftHashStream[j], rightHashStream[j], _comparer, cancellationToken);
            }
            outputRecipient.Receive(partitionedStream2);
        }
    }

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