Observable 总是订阅一次

Question

我为 RxSwift 编写异步单元测试，这是我的代码，我无法理解只订阅一次

class TestViewModel: NSObject {
    let result : Observable<Int>

     init(input:Observable<Int>) {
        result = input.flatMapLatest({ (value) -> Observable<Int> in

            return Observable.create({ (observer) -> Disposable in

                DispatchQueue.main.asyncAfter(deadline: DispatchTime.now() + 1, execute: {
                print("next"+"  \(value)")
                    observer.onNext(value)
                })

                return Disposables.create()
            })
        })
    }

}

    func testCount() {
        let expectation = XCTestExpectation(description: "async")
        let input = scheduler.createHotObservable([.next(100, 1),.next(200, 10)])
        let viewModel = TestViewModel.init(input: input.asObservable())
        viewModel.result.subscribe(onNext: { (value) in
            print("subscribe"+"   \(value)")
        }).disposed(by: disposeBag)
        scheduler.start()
        wait(for: [expectation], timeout: timeout)
    }

打印信息：

next  1
next  10
subscribe   10

我认为打印信息应该：

next  1
next  10
subscribe   1  
subscribe   10

有人可以给我建议吗？谢谢

Answer 1

这就是 flatMapLatest 运算符的工作方式。它基本上告诉 "map events into observables but use only recent observable's result"。因此，您将事件映射到两个可观察对象中：

1: --1秒-> 1

10: --1秒-> 10

目前最近可观察到的是 10。

尝试使用 flatMap 而不是 flatMapLatest。

您还应该尽可能避免 Observable.create。在您的特定情况下（延迟值），您可以使用 Observable.timer 或 Observable.just(...).delay(...).

Observable 总是订阅一次

Observable subscribe alway once issue

swift

rx-swift

rx-cocoa