Class FetcherPool<T>

Type Parameters

  • T

Hierarchy

  • PendingWorkPool<T>
    • FetcherPool

Constructors

constructor

Properties

coordinatorJob debouncedJob options skipSleep workFetcher

Methods

addWork checkComplete defaultCheckComplete get getCount getFetcher getFirstValue getPendingWork getSleepTime handleWork hasFinished loadPendingWork removeWork runJob skipNextSleep start stop

Constructors

constructor

Properties

Protected coordinatorJob

coordinatorJob: undefined | JobRunner

Protected debouncedJob

debouncedJob: undefined | DebouncedJobRunner

options

options: FetcherPoolOptions<T> & PendingWorkOptions<T>

Protected skipSleep

skipSleep: boolean

Protected workFetcher

workFetcher: Record<string, BaseHistoryFetcher<any>> = {}

Methods

addWork

  • Parameters

    • work: PendingWork<T> | PendingWork<T>[]

    Returns Promise<void>

Protected checkComplete

  • Parameters

    • works: PendingWork<T>[]

    Returns Promise<PendingWork<T>[]>

Protected defaultCheckComplete

get

  • Parameters

    • signature: string

    Returns Promise<undefined | PendingWork<T>>

getCount

  • Returns Promise<number>

Protected getFetcher

getFirstValue

  • Returns Promise<undefined | PendingWork<T>>

Protected getPendingWork

  • Parameters

    • Optional chunkSize: number

    Returns Promise<Generator<Promise<void>, any, unknown>>

Protected getSleepTime

Protected handleWork

  • Parameters

    • works: PendingWork<T>[]

    Returns Promise<number | void>

hasFinished

  • Returns Promise<void>

Protected loadPendingWork

  • Parameters

    • pendingWorkGen: AsyncIterator<StorageEntry<string, PendingWork<T>>, any, undefined>
    • size: number

    Returns Promise<PendingWork<T>[]>

removeWork

  • Parameters

    • work: PendingWork<T> | PendingWork<T>[]

    Returns Promise<void>

Protected runJob

  • Returns Promise<number>

skipNextSleep

  • Returns void

start

  • Returns Promise<void>

stop

  • Returns Promise<void>

Settings

Member Visibility

Theme

Generated using TypeDoc