Skip to main content

EventEmitterTransport

@totemsdk/pubsub-transport


@totemsdk/pubsub-transport / EventEmitterTransport

Class: EventEmitterTransport

In-process pub/sub transport backed by a Node.js EventEmitter. Useful for wiring together components in the same process without a broker.

Two EventEmitterTransport instances sharing the same bus EventEmitter form a bidirectional pub/sub channel: what one publishes, the other receives.

Implements

Constructors

Constructor

new EventEmitterTransport(bus?): EventEmitterTransport

Parameters

bus?

EventEmitter<DefaultEventMap>

Returns

EventEmitterTransport

Accessors

bus

Get Signature

get bus(): EventEmitter

Returns

EventEmitter

Methods

connect()

connect(): Promise<void>

Returns

Promise<void>

Implementation of

IPubSubTransport.connect


disconnect()

disconnect(): Promise<void>

Returns

Promise<void>

Implementation of

IPubSubTransport.disconnect


onMessage()

onMessage(handler): () => void

Parameters

handler

(message) => void

Returns

() => void

Implementation of

IPubSubTransport.onMessage


publish()

publish(topic, payload): Promise<void>

Parameters

topic

string

payload

string | Uint8Array<ArrayBufferLike>

Returns

Promise<void>

Implementation of

IPubSubTransport.publish


subscribe()

subscribe(topic): Promise<PubSubSubscription>

Parameters

topic

string

Returns

Promise<PubSubSubscription>

Implementation of

IPubSubTransport.subscribe