StreamCutoffAttachQueue

class StreamCutoffAttachQueue()

Constructors

constructor()

Properties

_deferredPromises
_latestPromise
_needsResorting
override

Methods

_deferPromise()
_dequeue()
_drainQueue()
_fetchNext()
_push()
_queue()
_resort()
activePromiseCount()
cutoffEnabled()
isEmpty()
isIdle()
killDeferred()
markDirty()
maxActivePromises()
push()
setCutoffScale()
update()
waitForIdle()

Constructors

StreamCutoffAttachQueue.constructor(cutoffScale, attachPriorityManager, maxActivePromises, compare, failureFailsAll)

Arguments:	cutoffScale (`number()`) – None attachPriorityManager (`AttachPriorityManager()`) – None maxActivePromises (`number()`) – None compare (CompareGreater <XmlAttachPriorityProxy>) – None failureFailsAll (`boolean()`) – None
Return type:	`StreamCutoffAttachQueue()`

Properties

StreamCutoffAttachQueue._deferredPromises

Type:	`PriorityQueue()` <`_DeferredPromise()` <ScsBuffer \| Response \| null, XmlAttachPriorityProxy>>

StreamCutoffAttachQueue._latestPromise

Type:	Promise <ScsBuffer \| Response \| null \| void>

StreamCutoffAttachQueue._needsResorting

Type:	boolean

StreamCutoffAttachQueue.override

Type:	any

Methods

_deferPromise

StreamCutoffAttachQueue._deferPromise(lazyPromise, compareValue)

Arguments:	lazyPromise (`Lazy()` <Promise <S>>) – None compareValue (XmlAttachPriorityProxy) – None
Return type:	Promise <S>

_dequeue

StreamCutoffAttachQueue._dequeue()

Return type:	`_DeferredPromise()` <ScsBuffer \| Response \| null, XmlAttachPriorityProxy>

_drainQueue

StreamCutoffAttachQueue._drainQueue()

Return type:	[`_DeferredPromise()` <T, U>]

_fetchNext

StreamCutoffAttachQueue._fetchNext()

Return type:	void

_push

StreamCutoffAttachQueue._push(lazyPromise, compareValue)

Arguments:	lazyPromise (LazyLike <Promise <S>>) – None compareValue (XmlAttachPriorityProxy) – None
Return type:	Promise <S>

_queue

StreamCutoffAttachQueue._queue(promise)

Arguments:	promise (`_DeferredPromise()` <ScsBuffer \| Response \| null, XmlAttachPriorityProxy>) – None
Return type:	void

_resort

StreamCutoffAttachQueue._resort()

Return type:	void

activePromiseCount

StreamCutoffAttachQueue.activePromiseCount()

Return type:	number

cutoffEnabled

StreamCutoffAttachQueue.cutoffEnabled()

Return type:	boolean

isEmpty

StreamCutoffAttachQueue.isEmpty()

Return type:	boolean

isIdle

StreamCutoffAttachQueue.isIdle()

Return type:	boolean

killDeferred

StreamCutoffAttachQueue.killDeferred()

Return type:	void

markDirty

StreamCutoffAttachQueue.markDirty()

Return type:	void

maxActivePromises

StreamCutoffAttachQueue.maxActivePromises()

Return type:	number

push

StreamCutoffAttachQueue.push(lazyPromise, compareValue)

Arguments:	lazyPromise (LazyLike <Promise <S>>) – None compareValue (XmlAttachPriorityProxy) – None
Return type:	Promise <S>

setCutoffScale

StreamCutoffAttachQueue.setCutoffScale(cutoffScale)

Arguments:	cutoffScale (`number()`) – None
Return type:	void

update

StreamCutoffAttachQueue.update()

Return type:	void

waitForIdle

StreamCutoffAttachQueue.waitForIdle()

Return type:	Promise <void>