Reactive Retry

@Retryable advice can also be applied to methods that return reactive types, such as an RxJava Flowable. For example:

Applying Retry Policy to Reactive Types

    @Retryable
    public Flowable<Book> streamBooks() {
        // ...

Applying Retry Policy to Reactive Types

    @Retryable
    Flowable<Book> streamBooks() {
        // ...

Applying Retry Policy to Reactive Types

    @Retryable
    open fun streamBooks(): Flowable<Book> {
        // ...

In this case @Retryable advice will apply the retry policy to the reactive type.