Class DirectMessageBus<Msg, Peer, InMsg>

constructor

• new DirectMessageBus<Msg, Peer, InMsg>(bus, self, peer, protocol?): DirectMessageBus<Msg, Peer, InMsg>

• Type Parameters

  • Msg = Uint8Array

  • Peer extends StringEquatable<Peer> = string

  • InMsg = Msg

  Parameters

  • bus: MessageBus<Msg, InMsg, PeerAwareMessageOptions<Peer>>

  • self: Peer

  • peer: Peer

  • protocol: string = ...

  Returns DirectMessageBus<Msg, Peer, InMsg>

Readonly id

Readonly peer

Readonly self

dispatch

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

• Dispatches a message.

  Parameters

  • message: Msg

  • Optional options: MessageOptions

  Returns MaybePromise<void>

getFullTopic

• getFullTopic(topic?): string

• Given a topic, returns the full topic ID for underlying message bus.

  Parameters

  • Optional topic: string

  Returns string

resolveTopic

• resolveTopic(fullTopic?): undefined | string

• Resolves a full topic ID to local topic ID.

  Parameters

  • Optional fullTopic: string

  Returns undefined | string

subscribe

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

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

  Parameters

  • handler: PeerAwareMessageHandler<InMsg, Peer>

  • Optional options: PeerAwareSubscribeOptions<InMsg, Peer>

  Returns MaybePromise<Unsubscribe>