BuildHashLookup()

override HashLookup< Wrapper< TGroupKey >, GroupKeyData > System.Linq.Parallel.OrderedGroupByIdentityQueryOperatorEnumerator< TSource, TGroupKey, TOrderKey >.BuildHashLookup ( )

inlineprotected

Definition at line 13 of file OrderedGroupByIdentityQueryOperatorEnumerator.cs.

    {
        HashLookup<Wrapper<TGroupKey>, GroupKeyData> hashLookup = new HashLookup<Wrapper<TGroupKey>, GroupKeyData>(new WrapperEqualityComparer<TGroupKey>(_keyComparer));
        Pair<TSource, TGroupKey> currentElement = default(Pair<TSource, TGroupKey>);
        TOrderKey currentKey = default(TOrderKey);
        int num = 0;
        while (_source.MoveNext(ref currentElement, ref currentKey))
        {
            if ((num++ & 0x3F) == 0)
            {
                _cancellationToken.ThrowIfCancellationRequested();
            }
            Wrapper<TGroupKey> key = new Wrapper<TGroupKey>(currentElement.Second);
            GroupKeyData value = null;
            if (hashLookup.TryGetValue(key, ref value))
            {
                if (_orderComparer.Compare(currentKey, value._orderKey) < 0)
                {
                    value._orderKey = currentKey;
                }
            }
            else
            {
                value = new GroupKeyData(currentKey, key.Value, _orderComparer);
                hashLookup.Add(key, value);
            }
            value._grouping.Add(currentElement.First, currentKey);
        }
        for (int i = 0; i < hashLookup.Count; i++)
        {
            hashLookup[i].Value._grouping.DoneAdding();
        }
        return hashLookup;
    }

References System.Linq.Parallel.OrderedGroupByQueryOperatorEnumerator< TSource, TGroupKey, TSource, TOrderKey >._cancellationToken, System.Linq.Parallel.OrderedGroupByQueryOperatorEnumerator< TSource, TGroupKey, TSource, TOrderKey >._keyComparer, System.Linq.Parallel.OrderedGroupByQueryOperatorEnumerator< TSource, TGroupKey, TSource, TOrderKey >._orderComparer, System.Linq.Parallel.OrderedGroupByQueryOperatorEnumerator< TSource, TGroupKey, TSource, TOrderKey >._source, System.Collections.Generic.Dictionary< TKey, TValue >.Add(), System.Collections.Generic.IComparer< in T >.Compare(), System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.key, System.Threading.CancellationToken.ThrowIfCancellationRequested(), System.Collections.Generic.Dictionary< TKey, TValue >.TryGetValue(), and System.value.