• Returns an Observable that mirrors the source Observable unless receiving a message with a response status code greater than or equal to 400. Then, the stream will end with an error and the source Observable unsubscribed.

    When receiving a message with the response status code ResponseStatusCodes.TERMINAL, the Observable emits this message and completes.

    If a message does not include a response status code, the message is emitted as is.

    Note that this operator is installed in MessageClient.request$ and IntentClient.request$.

    Type Parameters

    • BODY

    Returns MonoTypeOperatorFunction<TopicMessage<BODY>>

Generated using TypeDoc