InMemoryPubSubTransport
Defined in: packages/pubsub/src/memory-transport.ts:22
In-memory transport for tests, examples, and conformance execution.
Not durable - do not use in production. Specifically:
- No broker persistence (events lost on process restart)
- No delayed publish support (
notBeforeis ignored) - No retry semantics (immediate ack/reject only)
This transport exists so application logic can be tested without requiring Kafka/RabbitMQ/NATS infrastructure.
Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new InMemoryPubSubTransport(
options?):InMemoryPubSubTransport
Defined in: packages/pubsub/src/memory-transport.ts:32
Create an in-memory transport with optional transport defaults.
Parameters
Section titled “Parameters”options?
Section titled “options?”defaultSource?
Section titled “defaultSource?”string
Returns
Section titled “Returns”InMemoryPubSubTransport
Properties
Section titled “Properties”defaultSource?
Section titled “defaultSource?”
optionaldefaultSource?:string
Defined in: packages/pubsub/src/memory-transport.ts:28
Optional transport-level default CloudEvent source.
Implementation of
Section titled “Implementation of”dispositions
Section titled “dispositions”
readonlydispositions:Disposition[] =[]
Defined in: packages/pubsub/src/memory-transport.ts:26
Dispositions returned by deliveries this transport has invoked.
published
Section titled “published”
readonlypublished:PublishRequest[] =[]
Defined in: packages/pubsub/src/memory-transport.ts:24
Requests published through this transport, in publish order.
Methods
Section titled “Methods”close()
Section titled “close()”close():
Promise<void>
Defined in: packages/pubsub/src/memory-transport.ts:60
Clear the registered handler.
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”deliver()
Section titled “deliver()”deliver(
index?):Promise<Disposition>
Defined in: packages/pubsub/src/memory-transport.ts:65
Deliver a recorded publish request to the registered handler.
Parameters
Section titled “Parameters”index?
Section titled “index?”number = ...
Returns
Section titled “Returns”Promise<Disposition>
publish()
Section titled “publish()”publish(
request):Promise<void>
Defined in: packages/pubsub/src/memory-transport.ts:37
Record a publish request and immediately deliver it when subscribed.
Parameters
Section titled “Parameters”request
Section titled “request”Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”subscribe()
Section titled “subscribe()”subscribe(
handler,_request):Promise<Subscription>
Defined in: packages/pubsub/src/memory-transport.ts:47
Register the handler that receives future in-memory deliveries.
Parameters
Section titled “Parameters”handler
Section titled “handler”_request
Section titled “_request”Returns
Section titled “Returns”Promise<Subscription>