java - 重复当 rxJav -> rxJava2

Question

我在这里找到了 repeateWhen 的例子

 @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() 函数，也没有示例！请需要你的帮助