學(xué)習(xí)參考文章：
官方github庫(kù)及使用demo 官方
RxSwift 使用詳解系列 專(zhuān)題詳講
RxSwift: ReactiveX for Swift
RxSwift 入坑好多天 - 終于有了一點(diǎn)理解
RxSwift官方例子解析
Moya+ RxSwift+HandyJSON 優(yōu)雅處理網(wǎng)絡(luò)請(qǐng)求
用 RxSwift 為 Controller 瘦身(1)，優(yōu)雅的使用網(wǎng)絡(luò)請(qǐng)求(Moya) + 數(shù)據(jù)緩存(Cache)。
函數(shù)響應(yīng)式編程是種編程范式。它是通過(guò)構(gòu)建函數(shù)操作數(shù)據(jù)序列，然后對(duì)這些序列做出響應(yīng)的編程方式。
- RxSwift使用場(chǎng)景：
- target action：比如按鈕事件
- 代理：delegate
- 閉包回調(diào)：閉包
- NotificationCenter：通知的使用
- KVO
- 多個(gè)任務(wù)之間有依賴關(guān)系：先處理一個(gè)任務(wù)獲得結(jié)果后，再執(zhí)行另一個(gè)任務(wù)
- 等待多個(gè)并發(fā)任務(wù)完成后處理結(jié)果
- Observable - 產(chǎn)生事件
- Observer - 響應(yīng)事件
- Operator - 創(chuàng)建變化組合事件
- Disposable - 管理綁定（訂閱）的生命周期
- Schedulers - 線程隊(duì)列調(diào)配
- orEmpty
位于RxCocoa中，將String?的控制屬性轉(zhuǎn)為String的控制屬性。
/// Transforms control property of type `String?` into control property of type `String`.
public var orEmpty: RxCocoa.ControlProperty<String> { get }
- share(replay:scope:)
會(huì)返回一個(gè)新的事件序列，處理多個(gè)訂閱者導(dǎo)致被處理多次情況。
讓他們共享這一個(gè)源，而不是為他們單獨(dú)創(chuàng)建新的源。這樣可以減少不必要的開(kāi)支。
Returns an observable sequence that **shares a single subscription to the underlying sequence**, and immediately upon subscription replays elements in buffer.
- map
map 操作符將源 Observable 的每個(gè)元素應(yīng)用你提供的轉(zhuǎn)換方法，然后返回含有轉(zhuǎn)換結(jié)果的 Observable。 - flatMapLatest
僅僅執(zhí)行最新的信號(hào)，當(dāng)有新的信號(hào)來(lái)的時(shí)候，取消上一次未執(zhí)行完的整個(gè)序列
Projects each element of an observable sequence into a new sequence of observable sequences and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
- combineLatest
將多個(gè) Observables 中最新的元素通過(guò)一個(gè)函數(shù)組合起來(lái)，然后將這個(gè)組合的結(jié)果發(fā)出來(lái)。
多個(gè)序列中，任何一個(gè)發(fā)出元素，就由這多個(gè)序列中的最新的幾個(gè)元素，根據(jù)函數(shù)組合成一個(gè)序列，發(fā)出。
例：
let usernameValid = usernameOutlet.rx.text.orEmpty
.map { $0.count >= minimalUsernameLength }
.share(replay: 1) // without this map would be executed once for each binding, rx is stateless by default
let passwordValid = passwordOutlet.rx.text.orEmpty
.map { $0.count >= minimalPasswordLength }
.share(replay: 1)
let everythingValid = Observable.combineLatest(usernameValid, passwordValid) { $0 && $1 }
.share(replay: 1)
- disposed(by: disposeBag)
每一個(gè)綁定也是有生命周期的。并且這個(gè)綁定是可以被清除的。disposed(by: disposeBag)就是將綁定的生命周期交給disposeBag來(lái)管理。當(dāng)disposeBag被釋放的時(shí)候，那么里面尚未清除的綁定也就被清除了。這就相當(dāng)于是在用 ARC來(lái)管理綁定的生命周期。 - withLatestFrom
將兩個(gè)可觀察序列合并為一個(gè)可觀察序列，當(dāng)?shù)诙€(gè)源有新數(shù)據(jù)的時(shí)候，再發(fā)送第一個(gè)源，會(huì)將第二個(gè)源的新數(shù)據(jù)訂閱到。
// 拿到第二個(gè)序列的新數(shù)據(jù)
public func withLatestFrom<SecondO>(_ second: SecondO) -> RxSwift.Observable<SecondO.E> where SecondO : ObservableConvertibleType
// 拿到2個(gè)序列的新數(shù)據(jù)，并進(jìn)行操作之后返回
public func withLatestFrom<SecondO, ResultType>(_ second: SecondO, resultSelector: @escaping (Self.E, SecondO.E) throws -> ResultType) -> RxSwift.Observable<ResultType> where SecondO : ObservableConvertibleType
官方demo應(yīng)用：
signedIn = input.loginTaps.withLatestFrom(usernameAndPassword)
.flatMapLatest { pair in
return API.signup(pair.username, password: pair.password)
.observeOn(MainScheduler.instance)
.catchErrorJustReturn(false)
.trackActivity(signingIn)
}
.flatMapLatest { loggedIn -> Observable<Bool> in
let message = loggedIn ? "Mock: Signed in to GitHub." : "Mock: Sign in to GitHub failed"
return wireframe.promptFor(message, cancelAction: "OK", actions: [])
// propagate original value
.map { _ in
loggedIn
}
}
.share(replay: 1)
- throttle
忽略上一個(gè)信號(hào)的一段時(shí)間的變化,也就是說(shuō)一段時(shí)間沒(méi)有新的信號(hào)輸入，才會(huì)向下發(fā)送 - distinctUntilChanged
直到信號(hào)改變了再發(fā)送
