WrapPartitionedStreamHelper< TIgnoreKey, TKey >()

void System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >.WrapPartitionedStreamHelper< TIgnoreKey, TKey > ( PartitionedStream< Pair< TSource, TGroupKey >, TKey > hashStream, IPartitionedStreamRecipient< IGrouping< TGroupKey, TElement > > recipient, CancellationToken cancellationToken )

inlineprivate

Definition at line 37 of file GroupByQueryOperator.cs.

    {
        int partitionCount = hashStream.PartitionCount;
        PartitionedStream<IGrouping<TGroupKey, TElement>, TKey> partitionedStream = new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled);
        for (int i = 0; i < partitionCount; i++)
        {
            if (_elementSelector == null)
            {
                GroupByIdentityQueryOperatorEnumerator<TSource, TGroupKey, TKey> groupByIdentityQueryOperatorEnumerator = new GroupByIdentityQueryOperatorEnumerator<TSource, TGroupKey, TKey>(hashStream[i], _keyComparer, cancellationToken);
                partitionedStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)groupByIdentityQueryOperatorEnumerator;
            }
            else
            {
                partitionedStream[i] = new GroupByElementSelectorQueryOperatorEnumerator<TSource, TGroupKey, TElement, TKey>(hashStream[i], _keyComparer, _elementSelector, cancellationToken);
            }
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >._elementSelector, System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >._keyComparer, and System.cancellationToken.