WrapPartitionedStreamHelperOrdered< TKey >()

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

inlineprivate

Definition at line 56 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);
        IComparer<TKey> keyComparer = hashStream.KeyComparer;
        for (int i = 0; i < partitionCount; i++)
        {
            if (_elementSelector == null)
            {
                OrderedGroupByIdentityQueryOperatorEnumerator<TSource, TGroupKey, TKey> orderedGroupByIdentityQueryOperatorEnumerator = new OrderedGroupByIdentityQueryOperatorEnumerator<TSource, TGroupKey, TKey>(hashStream[i], _keySelector, _keyComparer, keyComparer, cancellationToken);
                partitionedStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)orderedGroupByIdentityQueryOperatorEnumerator;
            }
            else
            {
                partitionedStream[i] = new OrderedGroupByElementSelectorQueryOperatorEnumerator<TSource, TGroupKey, TElement, TKey>(hashStream[i], _keySelector, _elementSelector, _keyComparer, keyComparer, cancellationToken);
            }
        }
        recipient.Receive(partitionedStream);
    }

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