Dispose() [2/2]

override void System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >.Dispose ( bool disposed )

inlineprotectedvirtual

Reimplemented from System.Linq.Parallel.QueryOperatorEnumerator< Pair< TInputOutput, THashKey >, int >.

Definition at line 146 of file HashRepartitionEnumerator.cs.

    {
        if (_barrier != null)
        {
            if (_mutables == null || _mutables._currentBufferIndex == -1)
            {
                _barrier.Signal();
                _barrier = null;
            }
            _source.Dispose();
        }
    }

References System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._barrier, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >.Mutables._currentBufferIndex, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._mutables, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._source, System.Linq.Parallel.QueryOperatorEnumerator< TElement, TKey >.Dispose(), and System.Threading.CountdownEvent.Signal().