Class DenoKVMessageBus<T>

constructor

• new DenoKVMessageBus<T>(kv, defaultTopic?): DenoKVMessageBus<T>

• Type Parameters

  • T = unknown

  Parameters

  • kv: Kv

    Redis client to use.

  • defaultTopic: string = DEFAULT_TOPIC

    The default topic to publish to.

  Returns DenoKVMessageBus<T>

Readonly defaultTopic

close

• close(): void

• Closes this object and releases any system resource associated with it.

  Returns void

dispatch

• dispatch(message, options?): Promise<void>

• Dispatches a message.

  Parameters

  • message: T

  • Optional options: DenoKVMessageOptions

  Returns Promise<void>

subscribe

• subscribe(handler, options?): Promise<Unsubscribe>

• Subscribes to new messages and returns a handle to unsubscribe.

  Parameters

  • handler: MessageHandler<T>

  • Optional options: SubscribeOptions<T, object>

  Returns Promise<Unsubscribe>

topics

• topics(): IterableIterator<string>

• Returns the list of subscribed topics for this node.

  Returns IterableIterator<string>