在Android开发上，RxJava已经是非常重要的组成之一。最近在用Swift开发iOS应用，考虑在架构设计上使用RxSwift。
添加依赖
# Podfile
use_frameworks!
target 'YOUR_TARGET_NAME' do
pod 'RxSwift', '~> 5'
pod 'RxCocoa', '~> 5'
pod 'RxBlocking', '~> 5'
end
# RxTest and RxBlocking make the most sense in the context of unit/integration tests
target 'YOUR_TESTING_TARGET' do
pod 'RxTest', '~> 5'
end创建 Observable
import RxSwift
...
let observable = Observable<Int>.create { (observer) -> Disposable in
observer.onNext(1)
observer.onCompleted()
return Disposables.create()
}定义 onError调用
struct MyError:Error {
var message = ""
init(message:String) {
self.message = message
}
}
let observable = Observable<Int>.create { (observer) -> Disposable in
let error = MyError(message: "Test Error")
observer.onError(error)
return Disposables.create()
}subscribe
只定义一个回调
observable.subscribe({ it in
print("onNext \(it.element)")
})定义onNext和onError
observable.subscribe(onNext: { it in
print("onNext \(it)")
},onError: { error in
print((error as! MyError).message)
})定义onNext、onError和onCompleted
observable.subscribe(onNext: { it in
print("onNext \(it)")
},onError: { error in
print((error as! MyError).message)
},onCompleted: {
})RxBlocking
RxBlocking是RxSwift中另外一个单独的框架。跟RxTest一样，也需要进行pod引入框架，需要单独添加依赖。RxBlocking可以把RxSwift从异步响应变成同步，所以RxBlocking也多用来做单元测试。
pod 'RxBlocking'import RxSwift
import RxBlocking
...
do{
let result = try observable.toBlocking().first()
print("结果：\(result)")
}catch{
print((error as! MyError).message)
}应用场景
比如我们使用RxSwift实现图片上传，在发布动态的时候需要先上传图片然后调用基于RxSwift实现的网络请求。加上我们不想嵌套调用，就可以通过toBlocking同步调用。
RxTest
RxTest 是可以用来构建RxSwift自动化测试的包，需要单独需要进行pod引入框架。
