TY
Size: a a a
TY
TY
TY
AG
TY
AG
TY
AG
AG
AG
TY
AG
AG
Observable.just(1)
.doOnUnsubscribe(() -> System.out.println("Unsubscribed 1"))
.doOnSubscribe(() -> System.out.println("Subscribed 1"))
.flatMap(i -> Observable.error(new Throwable()))
.doOnUnsubscribe(() -> System.out.println("Unsubscribe 2"))
.doOnSubscribe(() -> System.out.println("Subscribed 2"))
.retryWhen(errors -> errors.take(3).doOnNext(th -> System.out.println(th)))
.subscribe(printSubscriber);
AG
AG
AG
TY
AG