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

void System.Linq.Parallel.GroupJoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >.WrapPartitionedStreamHelper< TLeftKey, TRightKey > ( PartitionedStream< Pair< TLeftInput, TKey >, TLeftKey > leftHashStream, HashLookupBuilder< IEnumerable< TRightInput >, TRightKey, TKey >[] rightLookupBuilders, IComparer< TRightKey > rightKeyComparer, IPartitionedStreamRecipient< TOutput > outputRecipient, int partitionCount, CancellationToken cancellationToken )

inlineprivate

Definition at line 73 of file GroupJoinQueryOperator.cs.

    {
        if (base.RightChild.OutputOrdered && base.LeftChild.OutputOrdered)
        {
            PairOutputKeyBuilder<TLeftKey, TRightKey> outputKeyBuilder = new PairOutputKeyBuilder<TLeftKey, TRightKey>();
            IComparer<Pair<TLeftKey, TRightKey>> outputKeyComparer = new PairComparer<TLeftKey, TRightKey>(leftHashStream.KeyComparer, rightKeyComparer);
            WrapPartitionedStreamHelper(leftHashStream, rightLookupBuilders, outputKeyBuilder, outputKeyComparer, outputRecipient, partitionCount, cancellationToken);
        }
        else
        {
            LeftKeyOutputKeyBuilder<TLeftKey, TRightKey> outputKeyBuilder2 = new LeftKeyOutputKeyBuilder<TLeftKey, TRightKey>();
            WrapPartitionedStreamHelper(leftHashStream, rightLookupBuilders, outputKeyBuilder2, leftHashStream.KeyComparer, outputRecipient, partitionCount, cancellationToken);
        }
    }

References System.cancellationToken.