在Android開發(fā)上，RxJava已經(jīng)是非常重要的組成之一。最近在用Swift開發(fā)iOS應(yīng)用，考慮在架構(gòu)設(shè)計上使用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

創(chuàng)建 Observable

let observable = Observable<Int>.create { (observer) -> Disposable in
    observer.onNext(1)
    observer.onCompleted()
    return Disposables.create()
}

定義 onError調(diào)用

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

只定義一個回調(diào)

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中另外一個單獨(dú)的框架。跟RxTest一樣，也需要進(jìn)行pod引入框架，需要單獨(dú)添加依賴。RxBlocking可以把RxSwift從異步響應(yīng)變成同步。

    pod 'RxBlocking'

do{
    let result = try observable.toBlocking().first()
    print("結(jié)果：\(result)")
}catch{
    print((error as! MyError).message)
}

應(yīng)用場景

比如我們使用RxSwift實(shí)現(xiàn)圖片上傳，在發(fā)布動態(tài)的時候需要先上傳圖片然后調(diào)用基于RxSwift實(shí)現(xiàn)的網(wǎng)絡(luò)請求。加上我們不想嵌套調(diào)用，就可以通過toBlocking同步調(diào)用。