System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator Class Reference

Public Member Functions
override bool	MoveNext ()
override void	Dispose ()
virtual void	Reset ()

Protected Attributes
QueryTaskGroupState	_taskGroupState

Package Functions
	OrderedPipeliningMergeEnumerator (OrderPreservingPipeliningMergeHelper< TOutput, TKey > mergeHelper, IComparer< Producer< TKey > > producerComparer)

Properties
override TOutput	Current [get]

Private Member Functions
void	ThrowIfInTearDown ()
bool	TryWaitForElement (int producer, ref Pair< TKey, TOutput > element)
bool	TryGetPrivateElement (int producer, ref Pair< TKey, TOutput > element)

Private Attributes
readonly OrderPreservingPipeliningMergeHelper< TOutput, TKey >	_mergeHelper
readonly FixedMaxHeap< Producer< TKey > >	_producerHeap
readonly TOutput[]	_producerNextElement
readonly Queue< Pair< TKey, TOutput > >[]	_privateBuffer
bool	_initialized

Detailed Description

Definition at line 25 of file OrderPreservingPipeliningMergeHelper.cs.

---

The documentation for this class was generated from the following file:

• source/System.Linq.Parallel/System.Linq.Parallel/OrderPreservingPipeliningMergeHelper.cs