我有以下代码-

        viewIsReady
            .flatMapLatest { [unowned self] _ in self.dependencies.authSvc.checkSession().asDriver(onErrorJustReturn: false) }
            .distinctUntilChanged()
            .delay(.seconds(2), scheduler: MainScheduler.instance) <-- without this test passes
            .bind(to: checkSessionComplete)
            .disposed(by: disposeBag)


我们提供了一个初始视图,并希望每次显示最少的时间。由于通过向checkSessionComplete发出信号来消除此视图,因此我添加了一个延迟,以允许异步操作完成并防止序列继续前进。

但是,为此的测试现在失败了,但是行为是正确的。

我应该如何测试包含delay运算符的操作?

   func test_on_check_session_response_emits() {
        let deps = TestDependencies()
        deps.authSvcSpy.stubbedCheckSessionResult = .just(true)

        DependencyInjector.dependencies = deps

        scheduler.scheduleAt(0) {
            self.sut.viewIsReady.onNext(())
        }

        let observer = scheduler.createObserver(AuthState.self)

        sut.checkSessionComplete
        .asObservable()
        .bind(to: observer)
        .disposed(by: disposeBag)

        scheduler.start()

        XCTAssertEqual(observer.events.count, 1)
    }


编辑

根据以下答案,我已经更新了Presenter-

final class StartPresenter {

    // Input
    let viewIsReady = PublishSubject<Void>()

    // Output
    let checkSessionComplete = PublishSubject<Void>()

    var scheduler: SchedulerType = MainScheduler.instance

    weak private var view: StartViewInterface?

    private lazy var disposeBag = DisposeBag()

    init(view: StartViewInterface?) {
        self.view = view

        viewIsReady
            .flatMapLatest { [unowned self] _ in self.dependencies.authSvc.checkSession().asDriver(onErrorJustReturn: false) }
            .distinctUntilChanged()
            .mapToVoid()
            .delay(.seconds(2), scheduler: scheduler)
            .bind(to: checkSessionComplete)
            .disposed(by: disposeBag)
    }
}


和我的测试用例

    func test_on_check_session_response_emits() {
         let deps = TestDependencies()
         deps.authSvcSpy.stubbedCheckSessionResult = .just(true)
         DependencyInjector.dependencies = deps

        sut.scheduler = testScheduler

        testScheduler.scheduleAt(0) {
            self.sut.viewIsReady.onNext(())
        }

        let observer = testScheduler.createObserver(Void.self)

        sut.checkSessionComplete
        .asObservable()
        .delay(.seconds(2), scheduler: testScheduler)
        .bind(to: observer)
        .disposed(by: disposeBag)

        testScheduler.start()

        XCTAssertEqual(observer.events.count, 1)
    }

}


如果.delay在链中,则测试仍然失败。

最佳答案

在您的代码中,您使用的是MainScheduler.instance,在测试过程中将不起作用。您需要注入测试计划程序并使用该计划程序,例如:.delay(.seconds(2), scheduler: scheduler)

关于swift - RxSwift测试现在失败。引入了delay,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/58768804/

10-12 12:20
查看更多