Class Queue

Index

Constructors

Properties

ackNotifier errorNotifier lock queue timeout

Methods

clear getState processAck processError processQueue push remove wait

Constructors

constructor

new Queue(): Queue
Returns Queue
- Defined in src/utils/queue.ts:12

Properties

`Private` ackNotifier

ackNotifier: SimpleEventDispatcher<number> = ...

`Private` errorNotifier

errorNotifier: SimpleEventDispatcher<PacketError> = ...

`Private` lock

lock: boolean = false

`Private` queue

queue: QueueItem[] = []

`Private` timeout

timeout: number

Methods

clear

clear(): void
Returns void
- Defined in src/utils/queue.ts:20

getState

getState(): QueueItem[]
Returns QueueItem[]
- Defined in src/utils/queue.ts:16

processAck

processAck(id): void
Parameters
- id: number
Returns void
- Defined in src/utils/queue.ts:69

processError

processError(e): void
Parameters
- e: PacketError
Returns void
- Defined in src/utils/queue.ts:73

processQueue

processQueue(writeToRadio): Promise<void>
Parameters
- writeToRadio: ((data) => Promise<void>)
  - - (data): Promise<void>
    - Parameters
      data: Uint8Array
      Returns Promise<void>
Returns Promise<void>
- Defined in src/utils/queue.ts:90

push

push(item): void
Parameters
- item: Omit<QueueItem, "promise" | "sent" | "added">
Returns void
- Defined in src/utils/queue.ts:24

remove

remove(id): void
Parameters
- id: number
Returns void
- Defined in src/utils/queue.ts:61

wait

wait(id): Promise<number>
Parameters
- id: number
Returns Promise<number>
- Defined in src/utils/queue.ts:82

Generated using TypeDoc