WrapPartitionedStreamHelper< TKey >()

void System.Linq.Parallel.DistinctQueryOperator< TInputOutput >.WrapPartitionedStreamHelper< TKey > ( PartitionedStream< Pair< TInputOutput, NoKeyMemoizationRequired >, TKey > hashStream, IPartitionedStreamRecipient< TInputOutput > recipient, CancellationToken cancellationToken )

inlineprivate

Definition at line 145 of file DistinctQueryOperator.cs.

    {
        int partitionCount = hashStream.PartitionCount;
        PartitionedStream<TInputOutput, TKey> partitionedStream = new PartitionedStream<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled);
        for (int i = 0; i < partitionCount; i++)
        {
            if (base.OutputOrdered)
            {
                partitionedStream[i] = new OrderedDistinctQueryOperatorEnumerator<TKey>(hashStream[i], _comparer, hashStream.KeyComparer, cancellationToken);
            }
            else
            {
                partitionedStream[i] = (QueryOperatorEnumerator<TInputOutput, TKey>)(object)new DistinctQueryOperatorEnumerator<TKey>(hashStream[i], _comparer, cancellationToken);
            }
        }
        recipient.Receive(partitionedStream);
    }

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