我有以下代码-
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/