TryGetPrivateElement()

bool System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.TryGetPrivateElement ( int producer, ref Pair< TKey, TOutput > element )

inlineprivate

Definition at line 159 of file OrderPreservingPipeliningMergeHelper.cs.

        {
            Queue<Pair<TKey, TOutput>> queue = _privateBuffer[producer];
            if (queue != null)
            {
                if (queue.Count > 0)
                {
                    element = queue.Dequeue();
                    return true;
                }
                _privateBuffer[producer] = null;
            }
            return false;
        }

References System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._privateBuffer, and System.Collections.Generic.Dictionary< TKey, TValue >.Count.

Referenced by System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.MoveNext(), and System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.TryWaitForElement().