我正在尝试创建一个轮询网络服务的流。目前,它查询服务,然后在短时间延迟后完成。我希望继续的流重新启动,而不是完成,从而永远轮询服务。但是repeat in RxSwift实际上是repeatElement,因此实际上生成了一个可观察的流。您可能会将这些concatMap转换成扁平的串行序列,但是RxSwift没有concatMap操作符。
那么
我有两个不同的观察点,它们的行为如下
Observable One behavior ->,这将被创建,一个DisposableObserver将订阅它,并对可观察的行为所发出的项做出反应。Observable two behavior ->这将在不同的时间创建并订阅不同的观察者,在订阅之后,它应该根据订阅了Observable two之后由Observable one