使用 RxSwift 进行长轮询

Question

我想用 RxSwift 发出一个简单的长轮询请求，可能类似于下面的 RxJava 代码：

api.loadHotels(searchRequest)
    .repeatWhen(obs -> observable.delay(3, TimeUnit.SECONDS))
    .takeUntil(searchResponse -> searchResponse.isCompleted)
    .subscribe(listener::hotelListLoaded);

在 RxSwift 中，有一个 repeatWhen 运算符将 ObservableConvertibleType 作为参数，而不是将链接的 Observable 作为参数传递给它的闭包，这与它在 RxJava 中的同义词不同。

我对 RxSwift 的期望：api.loadHotels(searchRequest).repeatWhen{result -> ObservableConvertibleType}，所以我可以编写与 RxJava 代码完全相同的逻辑。但我无法做到这一点。因为它只是作为 api.loadHotels(searchRequest).repeatWhen(ObservableConvertibleType) 完全相同的事情适用于 RxSwift 的 takeUntil 运算符。

但是我也尝试过： repeatWhen operator in RxSwift 和 repeatWhen substituter in RxSwift

所以我的问题是：如何在 RxSwift 中实现与给定 RxJava 代码相同的逻辑？我是不是弄错了 RxSwift 的当前 repeatWhen 和 takeUntil 运营商的工作流程？

Answer 1

这样的事情怎么样？：

let hotelRequest = api.loadHotels(searchRequest)

hotelRequest.repeatWhen {
    return hotelRequest.flatMapLatest { result in
        // now you have your chance to use `result -> ObservableConvertibleType`
    }
}