Skip to main content

MockPubSubTransport

@totemsdk/pubsub-transport


@totemsdk/pubsub-transport / MockPubSubTransport

Class: MockPubSubTransport

Mock pub/sub transport for unit tests. Records all published messages and supports manual message injection.

Implements

Constructors

Constructor

new MockPubSubTransport(): MockPubSubTransport

Returns

MockPubSubTransport

Properties

connected

connected: boolean = false


published

readonly published: object[] = []

payload

payload: string | Uint8Array<ArrayBufferLike>

topic

topic: string


subscriptions

readonly subscriptions: string[] = []

Methods

connect()

connect(): Promise<void>

Returns

Promise<void>

Implementation of

IPubSubTransport.connect


disconnect()

disconnect(): Promise<void>

Returns

Promise<void>

Implementation of

IPubSubTransport.disconnect


inject()

inject(topic, payload): void

Inject an inbound message — useful for simulating broker delivery in tests.

Parameters

topic

string

payload

string | Uint8Array<ArrayBufferLike>

Returns

void


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