StreamCutoffAttachQueue

class StreamCutoffAttachQueue()

Constructors


Constructors

StreamCutoffAttachQueue.constructor(cutoffScale, attachPriorityManager, maxActivePromises, compare, failureFailsAll)
Arguments:
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:
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:
Return type:

Promise <S>

_queue

StreamCutoffAttachQueue._queue(promise)
Arguments:
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:
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>