Symbol to get the application's symbolic name from the bean manager.
Key for obtaining the current outlet context using ContextService.
Default name for an outlet if no explicit name is specified.
Maps each message to its body.
Returns an Observable that mirrors the source Observable as long as there is at least one subscriber subscribed to the given topic. When the subscription count on the given topic drops to zero, the returned Observable completes. If there is no topic subscription present at the time when subscribing to the Observable, then it completes immediately.
This operator is similar to the RxJS {@link takeUntil} operator, but accepts a topic instead of a notifier Observable.
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 {@link RequestError 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$.
Generated using TypeDoc
Entry point for all public APIs of this package.