理解 RxSwift:为何要使用 RxSwift(一)swift
这篇文章是阅读 RxSwift: Reactive Programming with Swift 时记的笔记,介绍如何使用RxTest和RxBlocking对RxSwift编写单元测试。异步
书上使用RxTest和RxBlocking对一个 demo 进行了完整的单元测试和讲解,在这个过程当中,咱们能够熟悉一下RxSwift 单元测试的使用方法,了解单元测试的通常使用技巧和注意事项。async
Demo 是一个转换颜色的小应用,根据用户输入的16进制颜色代码自动转换为红、绿、蓝色值和颜色名字(如有)。post
Demo 是使用MVVM模式实现的,逻辑代码放在了ViewModel中,ViewController管理和控制View。ViewModel的主要代码以下:单元测试
// Convert hex text to color
color = hexString.asObservable()
.map { hex in
guard hex.characters.count == 7 else { return .clear }
let color = UIColor(hex: hex)
return color
}
.asDriver(onErrorJustReturn: .clear)
// Convert the color to an rgb tuple
rgb = color.asObservable()
.map { color in
var red: CGFloat = 0.0
var green: CGFloat = 0.0
var blue: CGFloat = 0.0
color.getRed(&red, green: &green, blue: &blue, alpha: nil)
let rgb = (Int(red * 255.0), Int(green * 255.0), Int(blue * 255.0))
return rgb
}
.asDriver(onErrorJustReturn: (0, 0, 0))
// Convert the hex text to a matching name
colorName = hexString.asObservable()
.map { hexString in
let hex = String(hexString.characters.dropFirst())
if let color = ColorName(rawValue: hex) {
return "\(color)"
} else {
return "--"
}
}
.asDriver(onErrorJustReturn: "")
复制代码
接下来,主要针对ViewModel编写单元测试。测试
首先介绍两个RxSwift单元测试的库,RxTest 和 RxBlocking,它们让编写测试用例更简单。ui
RxTest 是一个独立的库,须要经过pod单独安装。RxTest提供了不少有用的功能,例如TestScheduler,它是一个虚拟时间scheduler,能够在指定时间发出事件,包括next、completed和error。spa
RxBlocking 也是独立的库,也须要经过pod安装。它的做用是经过它的toBlocking(timeout:)方法将observable 转换成 BlockingObservable。阻塞当前线程,从而将异步操做转换为同步操做,使测试变得容易。
打开TestingTests组中的TestingViewModel.swift,在类的顶部定义两个属性:
var scheduler: ConcurrentDispatchQueueScheduler!
var disposeBag: Disposable!
复制代码
ConcurrentDispatchQueueScheduler 是并行队列调度器,封装了GCD的并行队列。
setUp()方法,每一个测试用例在开始前都会调用它。这里初始化一个新的 scheduler 和 viewModel。tearDown(),在每一个测试完成时调用,通常执行一些销毁操做。
func testColorIsRedWhenHexStringIsFF0000_async() {
let disposeBag = DisposeBag()
// 1
let expect = expectation(description: #function)
// 2
let expectedColor = UIColor(red: 1.0, green: 0.0, blue: 0.0, alpha:
1.0)
// 3
var result: UIColor!
}
复制代码
验证异步操做是否按预期运行,咱们在测试中建立指望 expectation,而后在异步操做成功后调用fulfill()方法,表示知足指望 expectation。
// 1
viewModel.color.asObservable()
.skip(1)
.subscribe(onNext: {
// 2
result = $0
expect.fulfill()
})
.disposed(by: disposeBag)
// 3
viewModel.hexString.value = "#ff0000"
// 4
waitForExpectations(timeout: 1.0) { error in
guard error == nil else {
XCTFail(error!.localizedDescription)
return
}
// 5
XCTAssertEqual(expectedColor, result)
}
复制代码
如今使用RxBlocking来实现一样的事情:
func testColorIsRedWhenHexStringIsFF0000() {
// 1
let colorObservable =
viewModel.color.asObservable().subscribeOn(scheduler)
// 2
viewModel.hexString.value = "#ff0000"
// 3
do {
guard let result = try colorObservable.toBlocking(timeout:
1.0).first() else { return }
XCTAssertEqual(result, .red)
} catch {
print(error)
}
}
复制代码
func testRgbIs010WhenHexStringIs00FF00() {
// 1
let rgbObservable =
viewModel.rgb.asObservable().subscribeOn(scheduler)
// 2
viewModel.hexString.value = "#00ff00"
// 3
let result = try! rgbObservable.toBlocking().first()!
XCTAssertEqual(0 * 255, result.0)
XCTAssertEqual(1 * 255, result.1)
XCTAssertEqual(0 * 255, result.2)
}
复制代码
func testColorNameIsRayWenderlichGreenWhenHexStringIs006636() {
// 1
let colorNameObservable =
viewModel.colorName.asObservable().subscribeOn(scheduler)
// 2
viewModel.hexString.value = "#006636"
// 3
XCTAssertEqual("rayWenderlichGreen", try!
colorNameObservable.toBlocking().first()!)
}
复制代码