Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface MessageHandler<T, E>

MessageHandler encapsulates bus handling and communication from the perspective of a consumer

Type parameters

  • T = any

  • E = any

Hierarchy

  • MessageHandler

Index

Methods

  • close(): boolean
  • error(payload: any): void
  • If responder is streaming, and the handler is open, send an error payload on the response channel

    Parameters

    • payload: any

    Returns void

  • getObservable(messageType?: MessageType): Observable<T>
  • / Get an observable for payloads

    Parameters

    • Optional messageType: MessageType

      optional filter for responses, requests or errors. If left blank, you get the firehose.

    Returns Observable<T>

  • isClosed(): boolean
  • tick(payload: any): void
  • if handler is streaming, and the handler is open, send a payload down the command channel

    Parameters

    • payload: any

      the payload you want to send.

    Returns void

Generated using TypeDoc