WrapPartitionedStreamHelper< TLeftKey, TRightKey, TOutputKey >()

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

inlineprivate

Definition at line 98 of file GroupJoinQueryOperator.cs.

    {
        PartitionedStream<TOutput, TOutputKey> partitionedStream = new PartitionedStream<TOutput, TOutputKey>(partitionCount, outputKeyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new HashJoinQueryOperatorEnumerator<TLeftInput, TLeftKey, IEnumerable<TRightInput>, TRightKey, TKey, TOutput, TOutputKey>(leftHashStream[i], rightLookupBuilders[i], _resultSelector, outputKeyBuilder, cancellationToken);
        }
        outputRecipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.GroupJoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >._resultSelector, and System.cancellationToken.