Повторять, когда rxJav -> rxJava2
Я нашел примеры с повтором когда здесь
@NonNull
private final PublishSubject<Void> updateSubject = PublishSubject.create();
private void load() {
repository
.getSomething()
.repeatWhen(repeatHandler ->
repeatHandler.flatMap(nothing -> updateSubject.asObservable()))
.subscribe(result -> {}, err -> {});
}
Но как записать это на rxJava 2? Это не функция.asObservable() и никаких примеров! Пожалуйста, вам нужна помощь