我在演示者上有模拟交互器和路由器用于单元测试
演示者方法:
private func presenterMethod(_ isOn: Bool) -> Driver<Bool> {
return interactor.interactorMethod(isOn)
.subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
.observeOn(MainScheduler.instance)
.do(onError: { [weak self] error in
self?.view.showError(error)
})
.asDriver(onErrorJustReturn: !isOn)
}
并测试
func testPresenterMethod() {
let trigger = self.scheduler.createHotObservable([
next(100, (false)),
next(200, (true)),
next(300, (false))
]).asDriverOnErrorJustComplete()
let observer = scheduler.createObserver(Bool.self)
let input = createInput(presenterTrigger: trigger)
let output = presenter.transform(input)
scheduler.scheduleAt(0, action: {
output.presenterMethodOutput.asObservable()
.subscribe(observer)
.disposed(by: self.disposeBag)
})
scheduler.start()
let results = observer.events.map {
$0.value.element
}
XCTAssertEqual(results, [false, true, false])
}
结果是空的
仅当我从presenterMethod中删除这些行时,此测试才能正常工作
.subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
.observeOn(MainScheduler.instance)
我尝试使用XCTestExpectation并在do(onNext:{})块中实现并获得相同的结果,仅在没有SubscribeOn背景的情况下工作。
方法工作在设备和模拟器上正确,presenterMethod在开关上被触发并发出正确的事件。该测试应如何编写才能与SubscribeOn后台一起使用?
最佳答案
实际上,您实际上希望传递给subscribeOn
的调度程序是演示者上的可配置变量。
由于最好同步执行测试,因此传入测试调度程序将确保无需等待异步执行。
struct Presenter {
let mainScheduler: SchedulerType
let backgroundScheduler: SchedulerType
init(backgroundScheduler: SchedulerType = ConcurrentDispatchQueueScheduler(qos: .background), mainScheduler: SchedulerType = MainScheduler.instance) {
self.mainScheduler = mainScheduler
self.backgroundScheduler = backgroundScheduler
}
private func presenterMethod(_ isOn: Bool) -> Driver<Bool> {
return interactor.interactorMethod(isOn)
.subscribeOn(backgroundScheduler)
.observeOn(mainScheduler)
.do(onError: { [weak self] error in
self?.view.showError(error)
})
.asDriver(onErrorJustReturn: !isOn)
}
}
然后,在创建演示者进行测试时
let presenter = Presenter(backgroundScheduler: self.scheduler, mainScheduler: self.scheduler)