bsideup
rxSingle { Observable.timer(1, MINUTES).await() }.takeUntil(() -> Observable.timer(5, SECONDS)).subscribe()