Class BroadcastChannelBroker

crypto

Static ReadonlyEVENT_TYPE

answer

• answer(channel: string, request: string | Message, answer: Message): BaseBroker

  answers a bidirectional message received usage, the client can use this method, to answer an incoming message in a precise manner so that the caller sending the bidirectional message knows how to deal with it this mechanism can be used for global storages where we have one answering entity per channel delivering the requested data, the request can be done asynchronously via promises waiting for answers

  Parameters

  • channel: string

    the channel the originating message

  • request: string | Message

    the requesting message

  • answer: Message

    the answer to the request

  Returns BaseBroker

asObservable

• asObservable(channel: string): Observable<Message>

  returns an observable on the baseBroker

  Parameters

  • channel: string

  Returns Observable<Message>

asSubject

• asSubject(channel: string): Subject<Message>

  binding into rxjs produces a subject which can be used via next calls to send messages on the other hand we

  Parameters

  • channel: string

  Returns Subject<Message>

request

• request(channel: string, message: string | Message): Promise<Message>

  idea... a bidirectional broadcast sends a message and waits for the first answer coming in from one of the receivers sending the message back with a messageIdentifier_broadCastId answer

  Parameters

  • channel: string
  • message: string | Message

  Returns Promise<Message>

unregisterListener

• unregisterListener(
      channel: string,
      listener: (msg: Message) => void,
  ): BaseBroker

  unregisters a listener from this channel

  Parameters

  • channel: string

    the channel to unregister from

  • listener: (msg: Message) => void

    the listener to unregister the channel from

  Returns BaseBroker