RxSwift的使用詳解

RxSwift的使用詳解

一. RxSwift簡(jiǎn)介

  • RxSwift是Swift函數(shù)響應(yīng)式編程的一個(gè)開源庫(kù)，由Github的ReactiveX組織開發(fā)、維護(hù)

  • 其他語言像C#, Java 和 JS 也有吟税，Rx.Net磕诊、RxJava、rxjs

  • RxSwift的目的是讓數(shù)據(jù)/事件流和異步任務(wù)能夠更方便的序列化處理冰单，能夠使用Swift進(jìn)行響應(yīng)式編程

1. RxSwift做了什么

  • RxSwift把我們程序中每一個(gè)操作都看成一個(gè)事件
  • 比如一個(gè)TextField中的文本改變幌缝，一個(gè)按鈕被點(diǎn)擊，或者一個(gè)網(wǎng)絡(luò)請(qǐng)求結(jié)束等球凰，每一個(gè)事件源就可以看成一個(gè)管道狮腿，也就是sequence
  • 比如TextField，當(dāng)我們改變里面的文本的時(shí)候呕诉，這個(gè)TextField就會(huì)不斷的發(fā)出事件缘厢，從他的這個(gè)sequence中不斷的流出，我們只需要監(jiān)聽這個(gè)sequence甩挫，每流出一個(gè)事件就做相應(yīng)的處理贴硫。
  • 同理，Button也是一個(gè)sequence伊者，每點(diǎn)擊一次就流出一個(gè)事件英遭。

2.1 RxSwift的核心思想是 Observable

  • sequence，Observable表示可監(jiān)聽或者可觀察亦渗，也就是說RxSwift的核心思想是可監(jiān)聽的序列挖诸。

  • 并且，Observable sequence可以接受異步信號(hào)法精，也就是說多律，信號(hào)是可以異步給監(jiān)聽者的

    • Observable(ObservableType) 和 SequenceType類似
    • ObservableType.subscribe 和 SequenceType.generate類似
    • 由于RxSwift支持異步獲得信號(hào)，所以用ObservableType.subscribe搂蜓，這和indexGenerator.next()類似

  • 其中SequenceType是Swift(2.3以前版本,之后的版本沒有該協(xié)議)中的一個(gè)協(xié)議狼荞，比如Swift中的Array就遵循這個(gè)協(xié)議，通過這個(gè)協(xié)議帮碰，你可以這樣的去操作一個(gè)Array

let array = [1,2,3,4,5]let array2 = array.filter({$0 > 1}).map({$0 * 2})//4 6 8 10var indexGenerator = array2.generate()let fisrt = indexGenerator.next() // 4let seoncd = indexGenerator.next() //6 復(fù)制代碼

2.2 RxSwift中相味，ObservableType.subscribe的回調(diào)（新的信號(hào)到來）一共有三

enum Event<Element>  {    case Next(Element)      // 新的信號(hào)到來    case Error(ErrorType)   // 信號(hào)發(fā)生錯(cuò)誤，序列不會(huì)再產(chǎn)生信號(hào)    case Completed          // 序列發(fā)送信號(hào)完成殉挽，不會(huì)再產(chǎn)生新的信號(hào)}protocol ObserverType {    func on(event: Event<Element>) //監(jiān)聽所有的信號(hào)}復(fù)制代碼

2.3 取消監(jiān)聽

Observable分為兩種

  • 在有限的時(shí)間內(nèi)會(huì)自動(dòng)結(jié)束（Completed/Error）,比如一個(gè)網(wǎng)絡(luò)請(qǐng)求當(dāng)作一個(gè)序列丰涉，當(dāng)網(wǎng)絡(luò)請(qǐng)求完成的時(shí)候奥帘，Observable自動(dòng)結(jié)束尤溜，資源會(huì)被釋放
  • 信號(hào)不會(huì)自己結(jié)束饵较，最簡(jiǎn)單的比如一個(gè)Timer土辩，每隔一段時(shí)間發(fā)送一個(gè)新的信號(hào)過來，這時(shí)候需要手動(dòng)取消監(jiān)聽摘符，來釋放相應(yīng)的資源
  • 比如一個(gè)label.rx.text是一個(gè)Obserable贤斜，通常需要這樣調(diào)用addDisposableTo(disposeBag)來讓其在deinit，也就是所有者要釋放的時(shí)候逛裤，自動(dòng)取消監(jiān)聽
class Observable<Element> {    func subscribe(observer: Observer<Element>) -> Disposable //調(diào)用Disposable的方法來取消 }復(fù)制代碼

當(dāng)然瘩绒，除了手動(dòng)釋放，RxSwift提供了一些操作符带族，比如 takeUntil來根據(jù)條件取消

sequence    .takeUntil(self.rx_deallocated) //當(dāng)對(duì)象要釋放的時(shí)候锁荔，取消監(jiān)聽    .subscribe {        print($0)    }復(fù)制代碼

二. RxSwift簡(jiǎn)單體驗(yàn)

  • 首先創(chuàng)建deinit屬性，也就是所有者要釋放的時(shí)候蝙砌，自動(dòng)取消監(jiān)聽
fileprivate lazy var bag = DisposeBag()復(fù)制代碼

1. RxSwift監(jiān)聽按鈕的點(diǎn)擊

  • 傳統(tǒng)方式:
button1.addTarget(self, action: #selector(btn1Click(_:)), for: .touchUpInside)復(fù)制代碼
  • RxSwift方式
button1.rx.tap.subscribe { (event) in    self.button1.setTitle("按鈕1", for: .normal)    print("button1")}.addDisposableTo(bag)        button2.rx.tap.subscribe { (event) in    self.textField2.text = "按鈕2被點(diǎn)擊了"}.addDisposableTo(bag)復(fù)制代碼

2. RxSwift監(jiān)聽UITextField的文字改變

  • 傳統(tǒng)做法,設(shè)置textField2.delegate = self
  • RxSwift方式

2-1. 用on方法實(shí)現(xiàn)

subscribe(<#T##on: (Event<Int>) -> Void##(Event<Int>) -> Void#>)復(fù)制代碼

textField1.rx.text.subscribe { (event: Event<String?>) in    //將UITextField文字改變的內(nèi)容顯示在Label中    self.label1.text = event.element!        print(event.element!!)}.addDisposableTo(bag)        textField2.rx.text.subscribe { (event: Event<String?>) in    print(event.element)//報(bào)警告    //輸出: Optional(Optional("jun"))}.addDisposableTo(bag)復(fù)制代碼

2-2. 用onNext方法實(shí)現(xiàn)

subscribe(on: (Event<Int>) -> Void)復(fù)制代碼

textField1.rx.text.subscribe(onNext: { (str: String?) in    self.label1.text = str!}).addDisposableTo(bag)復(fù)制代碼

3. RxSwift改變Label中文字

label1.rx.observe(String.self, "text").subscribe(onNext: { (str: String?) in    print(str!)}).addDisposableTo(bag)        label2.rx.observe(CGRect.self, "frame").subscribe(onNext: { (rect: CGRect?) in    print(rect!.width)}).addDisposableTo(bag)復(fù)制代碼

4. RxSwift監(jiān)聽UIScrollView的滾動(dòng)

scrollView.contentSize = CGSize(width: 1000, height: 0)scrollView.rx.contentOffset            .subscribe(onNext: { (point : CGPoint) in                print(point)            }).addDisposableTo(bag)  復(fù)制代碼

三. RxSwift常見操作

  • addDisposableTo(disposeBag)方法是讓其deinit阳堕，也就是所有者要釋放的時(shí)候，自動(dòng)取消監(jiān)聽
//創(chuàng)建baglet bag = DisposeBag()復(fù)制代碼

1. never

  • never就是創(chuàng)建一個(gè)sequence,但是不發(fā)出任何事件信號(hào)
let neverSqu = Observable<String>.never()neverSqu.subscribe { (_) in    //該語句不會(huì)執(zhí)行    print("This will never be printed")}.addDisposableTo(bag)//調(diào)用Disposable的方法來取消 復(fù)制代碼

2. empty

  • empty就是創(chuàng)建一個(gè)空的sequence,只能發(fā)出一個(gè)complected事件
Observable<Int>.empty().subscribe { (event) in    //該語句只會(huì)執(zhí)行一次    //輸出: completed    print(event)}.addDisposableTo(bag)復(fù)制代碼

3. just

  • just是創(chuàng)建一個(gè)sequence只能發(fā)出一種特定的事件择克，能正常結(jié)束
Observable<Int>.just(3).subscribe { (event) in    print(event)    /*該語句只會(huì)執(zhí)行兩次,分別輸出     1) next(3),語句結(jié)果     2) completed, 結(jié)束事件    */}.addDisposableTo(bag)        Observable.just("jun").subscribe { (event) in    print(event)    /*該語句只會(huì)執(zhí)行兩次,分別輸出     1) next(jun),語句結(jié)果     2) completed, 結(jié)束事件    */}.addDisposableTo(bag)復(fù)制代碼

4.of

  • of是創(chuàng)建一個(gè)sequence能發(fā)出很多種事件信號(hào)
Observable.of("a", "b", "2", "5.3")    .subscribe(onNext: { print($0) })    .addDisposableTo(bag)    //會(huì)分別輸出 "a", "b", "2", "5.3" Observable.of("a", "b", "2", "5.3").subscribe(onNext: { (event) in    print(event)    /*該語句只會(huì)執(zhí)行4次,分別輸出     1) next(a),語句結(jié)果     2) next(b),語句結(jié)果     3) next(2),語句結(jié)果     4) next(3.5),語句結(jié)果     */}, onError: nil, onCompleted: nil, onDisposed: nil).addDisposableTo(bag)   //每一個(gè)閉包都設(shè)置設(shè)置了 一個(gè)默認(rèn)值,故可以省略復(fù)制代碼

5. from

  • from就是從數(shù)組中創(chuàng)建sequence
Observable.from(["a", "b", "2", "5.3"]).subscribe { (event) in    print(event)    /*該語句只會(huì)執(zhí)行5次,分別輸出     1) next(a),語句結(jié)果     2) next(b),語句結(jié)果     3) next(2),語句結(jié)果     4) next(3.5),語句結(jié)果     5) completed, 結(jié)束事件     */}.addDisposableTo(bag)復(fù)制代碼

6. create

  • 我們也可以自定義可觀察的sequence恬总，那就是使用create
  • create操作符傳入一個(gè)觀察者observer，然后調(diào)用observer的onNext肚邢，onCompleted和onError方法壹堰。返回一個(gè)可觀察的obserable序列

1) 自定義方法創(chuàng)建observable的creat

6-1 無參創(chuàng)建creat

fileprivate func myobserable() -> Observable<Any> {    return Observable.create({ (observal: AnyObserver<Any>) -> Disposable in        observal.onNext("abc")        observal.onNext("12")        observal.onCompleted()        return Disposables.create()    })}復(fù)制代碼

6-2 添加參數(shù)創(chuàng)建creat

fileprivate func myJunst(element: String) -> Observable<String> {    return Observable.create({ (observal: AnyObserver<String>) -> Disposable in        observal.onNext(element)        observal.onCompleted()        return Disposables.create()    })}復(fù)制代碼

2) 在函數(shù)內(nèi)調(diào)用自定義方法

myobserable().subscribe(onNext: { print($0) }).addDisposableTo(bag)//該語句只會(huì)執(zhí)行2次,分別輸出"abc", "12"         myJunst(element: "jun").subscribe(onNext: { print($0) }).addDisposableTo(bag)//該語句只會(huì)執(zhí)行2次,分別輸出"jun" 復(fù)制代碼

7. range(給定范圍, 依次顯示)

  • range就是創(chuàng)建一個(gè)sequence，他會(huì)發(fā)出這個(gè)范圍中的從開始到結(jié)束的所有事件
  • Observable,必須指定數(shù)據(jù)類型
Observable<Int>.range(start: 1, count: 4).subscribe { (event: Event<Int>) in    print(event)    /*該語句只會(huì)執(zhí)行5次,分別輸出     1) next(1),語句結(jié)果     2) next(2),語句結(jié)果     3) next(3),語句結(jié)果     4) next(4),語句結(jié)果     5) completed, 結(jié)束事件     */}.addDisposableTo(bag)復(fù)制代碼

8. repeatElement(重復(fù)執(zhí)行)

創(chuàng)建一個(gè)sequence骡湖，發(fā)出特定的事件n次

Observable.repeatElement("quanjun")    .take(3)    .subscribe(onNext: { print($0) })    .addDisposableTo(bag)    //該語句只會(huì)執(zhí)行3次,每次都輸出"quanjun"  復(fù)制代碼

9. generate(類似于for循環(huán))

  • generate是創(chuàng)建一個(gè)可觀察sequence贱纠，當(dāng)初始化的條件為true的時(shí)候，他就會(huì)發(fā)出所對(duì)應(yīng)的事件
let generate = Observable.generate(initialState: 0, condition: { $0 < 5 }, iterate: { $0 + 2 })generate.subscribe({ print($0) }).addDisposableTo(bag)                /*1> 輸出順序:         next(0)         next(2)         next(4)         completed                  2> 以上代碼可以理解為for循環(huán)處理邏輯        for (Int i = 0; i < 5; i++) {            print(i)        }        */復(fù)制代碼

10. error(發(fā)出錯(cuò)誤信號(hào))

  • 創(chuàng)建一個(gè)可觀察序列响蕴，但不發(fā)出任何正常的事件谆焊，只發(fā)出error事件并結(jié)束
 let error = NSError(domain: "錯(cuò)誤", code: 10, userInfo: nil) as Error Observable<Any>.error(error)            .subscribe({ print($0) })            .addDisposableTo(bag)        //輸出: error(Error Domain=錯(cuò)誤 Code=10 "(null)")復(fù)制代碼

四. RxSwift中Subjects

  • Subjects是什么?

    • Subjet是observable和Observer之間的橋梁，一個(gè)Subject既是一個(gè)Obserable也是一個(gè)Observer浦夷，他既可以發(fā)出事件懊渡，也可以監(jiān)聽事件

1. PublishSubject

  • 當(dāng)你訂閱PublishSubject的時(shí)候，你只能接收到訂閱他之后發(fā)生的事件军拟。subject.onNext()發(fā)出onNext事件，對(duì)應(yīng)的還有onError()和onCompleted()事件
let pSubject = PublishSubject<String>()pSubject.subscribe { (event: Event<String>) in        print("2--", event)    }.addDisposableTo(bag)print("1--------------")        pSubject.onNext("T")pSubject.onNext("Q")        pSubject.subscribe { (event: Event<String>) in         print("3--", event)    }.addDisposableTo(bag)pSubject.onNext("J")            /*輸出順序?yàn)?         1--------------         2-- next(T)         2-- next(Q)         2-- next(J)         3-- next(J)     */ 復(fù)制代碼

2. ReplaySubject

  • 當(dāng)你訂閱ReplaySubject的時(shí)候誓禁，你可以接收到訂閱他之后的事件懈息，但也可以接受訂閱他之前發(fā)出的事件，接受幾個(gè)事件取決與bufferSize的大小
  • createUnbounded()表示接受所有事件
  • create(bufferSize: 4) 表示可接受到的訂閱他之前的事件的個(gè)數(shù),但是訂閱他之后的事件一定會(huì)觸發(fā)

2-1. createUnbounded()表示接受所有事件

let rSubject = ReplaySubject<String>.createUnbounded()rSubject.onNext("T")rSubject.onNext("Q")rSubject.subscribe { (event: Event<String>) in         print("0--", event)    }.addDisposableTo(bag)        rSubject.onNext("J") /*輸出順序?yàn)?     0-- next(T)     0-- next(Q)     0-- next(J)  */復(fù)制代碼

2-2. create(bufferSize: 4) 表示可接受到的訂閱他之前的事件的個(gè)數(shù)

let rSubject1 = ReplaySubject<String>.create(bufferSize: 1)rSubject1.onNext("T")rSubject1.onNext("Q")rSubject1.subscribe { (event: Event<String>) in            print("4--", event)        }.addDisposableTo(bag)        rSubject1.onNext("J") /*輸出順序?yàn)?     4-- next(Q)     4-- next(J)  */  復(fù)制代碼

3. BehaviorSubject

  • 當(dāng)你訂閱了BehaviorSubject摹恰，你會(huì)接受到訂閱之前的最后一個(gè)事件,訂閱之后的事件一定會(huì)觸發(fā)
let bSubject = BehaviorSubject(value: "G")bSubject.subscribe { (event: Event<String>) in        print("5--", event)    }.addDisposableTo(bag)        bSubject.onNext("Y")bSubject.onNext("Q")        bSubject.subscribe { (event: Event<String>) in        print("6--", event)    }.addDisposableTo(bag)        bSubject.onNext("J") /*輸出順序?yàn)?         5-- next(G)         5-- next(Y)         5-- next(Q)         6-- next(Q)         5-- next(J)         6-- next(J) */ 復(fù)制代碼

4. Variable

Variable是BehaviorSubject一個(gè)包裝箱辫继，就像是一個(gè)箱子一樣怒见，使用的時(shí)候需要調(diào)用asObservable()拆箱，里面的value是一個(gè)BehaviorSubject姑宽，他不會(huì)發(fā)出error事件遣耍，但是會(huì)自動(dòng)發(fā)出completed事件。
  • 1> 相當(dāng)于對(duì)BehaviorSubject進(jìn)行裝箱
  • 2> 如果想將Variable當(dāng)成Obserable, 讓訂閱者進(jìn)行訂閱時(shí), 需要調(diào)用asObserable拆箱轉(zhuǎn)成Obserable
  • 3> 如果Variable打算發(fā)出事件, 直接修改對(duì)象的value即可
  • 4> 當(dāng)事件結(jié)束時(shí),Variable會(huì)自動(dòng)發(fā)出completed事件
let variable = Variable("S")variable.asObservable().subscribe { (event) in        print("7--", event)    }.addDisposableTo(bag)        variable.value = "D"variable.value = "Q"        variable.asObservable().subscribe { (event) in        print("8--", event)    }.addDisposableTo(bag)        variable.value = "j" /*輸出順序?yàn)?         7-- next(S)         7-- next(D)         7-- next(Q)         8-- next(Q)         7-- next(j)         8-- next(j)         7-- completed         8-- completed  */ 復(fù)制代碼
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 人面猴
    序言：七十年代末炮车，一起剝皮案震驚了整個(gè)濱河市舵变，隨后出現(xiàn)的幾起案子，更是在濱河造成了極大的恐慌瘦穆，老刑警劉巖纪隙，帶你破解...
    沈念sama閱讀 218,941評(píng)論 6贊 508
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現(xiàn)場(chǎng)離奇詭異扛或，居然都是意外死亡绵咱，警方通過查閱死者的電腦和手機(jī)，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,397評(píng)論 3贊 395
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門熙兔，熙熙樓的掌柜王于貴愁眉苦臉地迎上來悲伶，“玉大人，你說我怎么就攤上這事住涉◆镲保” “怎么了？”我有些...
    開封第一講書人閱讀 165,345評(píng)論 0贊 356
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵秆吵，是天一觀的道長(zhǎng)淮椰。 經(jīng)常有香客問我，道長(zhǎng)纳寂，這世上最難降的妖魔是什么主穗？ 我笑而不...
    開封第一講書人閱讀 58,851評(píng)論 1贊 295
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任，我火速辦了婚禮毙芜，結(jié)果婚禮上忽媒，老公的妹妹穿的比我還像新娘。我一直安慰自己腋粥，他們只是感情好晦雨，可當(dāng)我...
    茶點(diǎn)故事閱讀 67,868評(píng)論 6贊 392
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布。 她就那樣靜靜地躺著隘冲，像睡著了一般闹瞧。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上展辞，一...
    開封第一講書人閱讀 51,688評(píng)論 1贊 305
  • 城市分裂傳說
    那天奥邮，我揣著相機(jī)與錄音，去河邊找鬼。 笑死洽腺，一個(gè)胖子當(dāng)著我的面吹牛脚粟，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播蘸朋，決...
    沈念sama閱讀 40,414評(píng)論 3贊 418
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼核无，長(zhǎng)吁一口氣：“原來是場(chǎng)噩夢(mèng)啊……” “哼！你這毒婦竟也來了藕坯？” 一聲冷哼從身側(cè)響起团南，我...
    開封第一講書人閱讀 39,319評(píng)論 0贊 276
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對(duì)情侶失蹤，失蹤者是張志新（化名）和其女友劉穎堕担，沒想到半個(gè)月后已慢，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體，經(jīng)...
    沈念sama閱讀 45,775評(píng)論 1贊 315
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡霹购，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,945評(píng)論 3贊 336
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年佑惠，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片齐疙。...
    茶點(diǎn)故事閱讀 40,096評(píng)論 1贊 350
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡膜楷，死狀恐怖，靈堂內(nèi)的尸體忽然破棺而出贞奋，到底是詐尸還是另有隱情赌厅，我是刑警寧澤，帶...
    沈念sama閱讀 35,789評(píng)論 5贊 346
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布轿塔，位于F島的核電站特愿，受9級(jí)特大地震影響，放射性物質(zhì)發(fā)生泄漏勾缭。R本人自食惡果不足惜揍障，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,437評(píng)論 3贊 331
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望俩由。 院中可真熱鬧毒嫡，春花似錦、人聲如沸幻梯。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,993評(píng)論 0贊 22
  • 一樁弒父案，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)碘梢。三九已至咬摇，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間煞躬，已是汗流浹背肛鹏。 一陣腳步聲響...
    開封第一講書人閱讀 33,107評(píng)論 1贊 271
  • 情欲美人皮
    我被黑心中介騙來泰國(guó)打工， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人龄坪。 一個(gè)月前我還...
    沈念sama閱讀 48,308評(píng)論 3贊 372
  • 代替公主和親
    正文 我出身青樓，卻偏偏與公主長(zhǎng)得像复唤，于是被迫代替她去往敵國(guó)和親健田。 傳聞我的和親對(duì)象是個(gè)殘疾皇子，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,037評(píng)論 2贊 355

推薦閱讀更多精彩內(nèi)容