12

RxTest和RxBlocking属于RxSwift库，需要单独的导入。
RxTest可测试Rx代码，它包括TestScheduler。
RxBlocking可以将一个普通的可观察序列转换为一个可观察的阻塞序列，它将阻塞正在运行的线程，直到可观察序列完成或超时为止，让测试异步操作更加容易。

RxTest

RxTest为测试公开了两种可观察性。

• HotObservables：不管是否有任何订阅者，HotObservables都会使用测试scheduler在指定的时间重播事件。
• ColdObservables：ColdObservables的工作方式更像普通的可观察对象，在订阅时将其元素重新播放给新订阅者。

Schedulers

Schedulers主要用来指定执行队列。
有如下内置类型：

• SerialDispatchQueueScheduler：在指定的串行调度队列上调度工作。
• ConcurrentDispatchQueueScheduler：在并发调度队列上调度工作。
• OperationQueueScheduler：在指定的NSOperations队列上执行工作。

我们也可以自定义Schedulers，要遵循ImmediateScheduler协议。

常用单例：

• CurrentThreadScheduler：表示当前线程，是默认的调度器。
• MainScheduler：表示通常用于所有ui相关工作的主线程。

Testing with RxBlocking

现在我们进行一个测试。

# RxTests 和 RxBlocking 将在单元/集成测试中起到重要作用
target 'YOUR_TESTING_TARGET' do
    pod 'RxBlocking', '~> 5.0'
    pod 'RxTest', '~> 5.0'
end

第一步，先创建一个10、20和30的可观察序列，如下所示:

func testBlocking(){
        let observableToTest = Observable.of(10, 20, 30)
}

第二步，调用toBlocking():

let result = observableToTest.toBlocking()

toBlocking()将一个常规的可观察序列转变为一个阻塞的可观察序列，如下图所示:

第三步，封装在do catch语句中，添加AssertEquals语句，如下所示:

func testBlocking(){
        let observableToTest = Observable.of(10, 20, 30)
        do{
            let result = try observableToTest.toBlocking().first()
            XCTAssertEqual(result, 10)
        } catch {
            XCTFail(error.localizedDescription)
        }
}

第四步，运行测试，可以看到测试通过。

当然，我们也可以通过try!：

func testBlocking(){
        let observableToTest = Observable.of(10, 20, 30)
//        do{
//            let result = try observableToTest.toBlocking().first()
//            XCTAssertEqual(result, 10)
//        } catch {
//            XCTFail(error.localizedDescription)
//        }
        XCTAssertEqual(try! observableToTest.toBlocking().first(), 10)
}

为了测试异步操作，我们将再编写一个测试。这一次，我们将在后台线程上使用一个并发调度程序，如下:

func testAsynchronousToArry(){
        let scheduler = ConcurrentDispatchQueueScheduler(qos: .background)
}

第一步，创建一个包含简单整数的可观察序列，使用map将每个值加倍，如下所示:

let intObservbale = Observable.of(10, 20, 30)
            .map{ $0 * 2 }

第二步，订阅scheduler:

let intObservbale = Observable.of(10, 20, 30)
            .map{ $0 * 2 }
            .subscribeOn(scheduler)

第三步，跟上个测试一样，将其封装到do catch语句中，调用toBlocking，如下:

do{
   let result = try intObservbale.observeOn(MainScheduler.instance).toBlocking().toArray()
    } catch {   
    }

第四步，添加断言:

do{
   let result = try intObservbale.observeOn(MainScheduler.instance).toBlocking().toArray()
            XCTAssertEqual(result, [20, 40, 60])
     } catch {
            XCTFail(error.localizedDescription)
     }

第五步，运行，测试通过：