PURISTA API / @purista/core / PendingInvocationRegistry
Class: PendingInvocationRegistry<T>
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:10
Type Parameters
T
T = unknown
Constructors
Constructor
new PendingInvocationRegistry<
T>(options?):PendingInvocationRegistry<T>
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:14
Parameters
options?
onLateResponse?
(correlationId) => void
retentionMs?
number
Returns
PendingInvocationRegistry<T>
Accessors
size
Get Signature
get size():
number
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:21
Returns
number
Methods
clear()
clear():
void
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:82
Returns
void
getPendingMap()
getPendingMap():
Map<string,PendingInvocation<T>>
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:25
Returns
Map<string, PendingInvocation<T>>
register()
register(
correlationId,timeoutMs,traceId):Promise<T>
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:29
Parameters
correlationId
string
timeoutMs
number
traceId
string | undefined
Returns
Promise<T>
reject()
reject(
correlationId,error):"rejected"|"late"|"missing"
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:64
Parameters
correlationId
string
error
unknown
Returns
"rejected" | "late" | "missing"
rejectAll()
rejectAll(
error):void
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:73
Parameters
error
unknown
Returns
void
resolve()
resolve(
correlationId,payload):"late"|"missing"|"resolved"
Defined in: core/EventBridge/PendingInvocationRegistry.impl.ts:55
Parameters
correlationId
string
payload
T
Returns
"late" | "missing" | "resolved"