學(xué)習(xí)參考文章：
官方github庫及使用demo 官方
RxSwift 使用詳解系列 專題詳講
RxSwift: ReactiveX for Swift
RxSwift 入坑好多天 - 終于有了一點理解
RxSwift官方例子解析
Moya+ RxSwift+HandyJSON 優(yōu)雅處理網(wǎng)絡(luò)請求
用 RxSwift 為 Controller 瘦身(1)，優(yōu)雅的使用網(wǎng)絡(luò)請求(Moya) + 數(shù)據(jù)緩存(Cache)。
函數(shù)響應(yīng)式編程是種編程范式。它是通過構(gòu)建函數(shù)操作數(shù)據(jù)序列，然后對這些序列做出響應(yīng)的編程方式。
- RxSwift使用場景：
- target action：比如按鈕事件
- 代理：delegate
- 閉包回調(diào)：閉包
- NotificationCenter：通知的使用
- KVO
- 多個任務(wù)之間有依賴關(guān)系：先處理一個任務(wù)獲得結(jié)果后，再執(zhí)行另一個任務(wù)
- 等待多個并發(fā)任務(wù)完成后處理結(jié)果
- Observable - 產(chǎn)生事件
- Observer - 響應(yīng)事件
- Operator - 創(chuàng)建變化組合事件
- Disposable - 管理綁定（訂閱）的生命周期
- Schedulers - 線程隊列調(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:)
會返回一個新的事件序列，處理多個訂閱者導(dǎo)致被處理多次情況。
讓他們共享這一個源，而不是為他們單獨創(chuàng)建新的源。這樣可以減少不必要的開支。
Returns an observable sequence that **shares a single subscription to the underlying sequence**, and immediately upon subscription replays elements in buffer.
- map
map 操作符將源 Observable 的每個元素應(yīng)用你提供的轉(zhuǎn)換方法，然后返回含有轉(zhuǎn)換結(jié)果的 Observable。 - flatMapLatest
僅僅執(zhí)行最新的信號，當(dāng)有新的信號來的時候，取消上一次未執(zhí)行完的整個序列
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
將多個 Observables 中最新的元素通過一個函數(shù)組合起來，然后將這個組合的結(jié)果發(fā)出來。
多個序列中，任何一個發(fā)出元素，就由這多個序列中的最新的幾個元素，根據(jù)函數(shù)組合成一個序列，發(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)
每一個綁定也是有生命周期的。并且這個綁定是可以被清除的。disposed(by: disposeBag)就是將綁定的生命周期交給disposeBag來管理。當(dāng)disposeBag被釋放的時候，那么里面尚未清除的綁定也就被清除了。這就相當(dāng)于是在用 ARC來管理綁定的生命周期。 - withLatestFrom
將兩個可觀察序列合并為一個可觀察序列，當(dāng)?shù)诙€源有新數(shù)據(jù)的時候，再發(fā)送第一個源，會將第二個源的新數(shù)據(jù)訂閱到。
// 拿到第二個序列的新數(shù)據(jù)
public func withLatestFrom<SecondO>(_ second: SecondO) -> RxSwift.Observable<SecondO.E> where SecondO : ObservableConvertibleType
// 拿到2個序列的新數(shù)據(jù)，并進行操作之后返回
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
忽略上一個信號的一段時間的變化,也就是說一段時間沒有新的信號輸入，才會向下發(fā)送 - distinctUntilChanged
直到信號改變了再發(fā)送
