Class PendingRequestMap<Id, Value>

A timeout-aware correlation map for request/response protocols.

Type Parameters

Id
Value

Index

Constructors

Methods

create delete reject rejectAll resolve

Constructors

constructor

new PendingRequestMap<Id, Value>(): PendingRequestMap<Id, Value>
Type Parameters
- Id
- Value
Returns PendingRequestMap<Id, Value>

Methods

create

create(id: Id, timeoutMs: number, timeoutMessage: string): Promise<Value>
Parameters
- id: Id
- timeoutMs: number
- timeoutMessage: string
Returns Promise<Value>
- Defined in sdk/src/shared/pending-request-map.ts:12

delete

delete(id: Id): void
Parameters
- id: Id
Returns void
- Defined in sdk/src/shared/pending-request-map.ts:38

reject

reject(id: Id, error: Error): boolean
Parameters
- id: Id
- error: Error
Returns boolean
- Defined in sdk/src/shared/pending-request-map.ts:31

rejectAll

rejectAll(error: Error): void
Parameters
- error: Error
Returns void
- Defined in sdk/src/shared/pending-request-map.ts:44

resolve

resolve(id: Id, value: Value): boolean
Parameters
- id: Id
- value: Value
Returns boolean
- Defined in sdk/src/shared/pending-request-map.ts:24