Type alias MessagingProvider<InboundT, OutboundT>

MessagingProvider<InboundT, OutboundT>: {
    message$: Observable<InboundT>;
    send(message) => void;
    send<ResponseT>(message, responseMatcher) => Observable<ResponseT>;
}

Type Parameters

  • InboundT

  • OutboundT

Type declaration

  • Readonly message$: Observable<InboundT>
  • send:function
    • send(message): void

    • Send one way Notification.

      Parameters

      • message: OutboundT

        notification message

      Returns void

    • send<ResponseT>(message, responseMatcher): Observable<ResponseT>

    • Send Request, pick corresponding Response.

      Type Parameters

      • ResponseT

      Parameters

      • message: OutboundT

        outbound notification / request

      • responseMatcher: Typeguard<ResponseT, InboundT>

        picks the corresponding response

      Returns Observable<ResponseT>

      last response that replays for later subscriptions

Settings

Member Visibility

Theme

Generated using TypeDoc