WrapPartitionedStreamHelper< TLeftKey, TRightKey >()

void System.Linq.Parallel.IntersectQueryOperator< TInputOutput >.WrapPartitionedStreamHelper< TLeftKey, TRightKey > ( PartitionedStream< Pair< TInputOutput, NoKeyMemoizationRequired >, TLeftKey > leftHashStream, PartitionedStream< TInputOutput, TRightKey > rightPartitionedStream, IPartitionedStreamRecipient< TInputOutput > outputRecipient, CancellationToken cancellationToken )

inlineprivate

Definition at line 175 of file IntersectQueryOperator.cs.

    {
        int partitionCount = leftHashStream.PartitionCount;
        PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> partitionedStream = ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(rightPartitionedStream, null, null, _comparer, cancellationToken);
        PartitionedStream<TInputOutput, TLeftKey> partitionedStream2 = new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled);
        for (int i = 0; i < partitionCount; i++)
        {
            if (base.OutputOrdered)
            {
                partitionedStream2[i] = new OrderedIntersectQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], partitionedStream[i], _comparer, leftHashStream.KeyComparer, cancellationToken);
            }
            else
            {
                partitionedStream2[i] = (QueryOperatorEnumerator<TInputOutput, TLeftKey>)(object)new IntersectQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], partitionedStream[i], _comparer, cancellationToken);
            }
        }
        outputRecipient.Receive(partitionedStream2);
    }

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