携手创造，一同生长！这是我参加「日新计划 8 月更文挑战」的第28天，点击检查活动详情

本文首要认识RxSwift的原理，以及简略运用，完结监听照应操作

首要内容：

  1. 照应式编程的认识
  2. RxSwift的原理认识
  3. RxSwift的简略运用

Swift基础语法文章汇总

1、 照应式编程

照应式编程（Reactive Programming ，简称RP），也是一种编程范式，于1997年提出，可以简化异步编程，提供更优雅的数据绑定。
一般与函数式融合在一同，所以也会叫做：函数照应式编程（ Functional Reactive Programming ，简称FRP）

框架介绍

比较老练的、闻名的照应式框架有两种：

  • ReactiveCocoa，简称RAC，只有OC和Swift版别
  • ReactiveX，简称Rx，有多种编程言语版别，没有OC的，有RxSwift（RxSwift（ReactiveX for Swift）， ReactiveX的Swift版别）

2、 RxSwift的原理

两个中心人物：

  • Observable：担任发送工作（Event）
  • Observer：担任订阅Observable ，监听Observable发送的工作（ Event）

订阅和监听进程：

说明：

  1. Observer先订阅Observable。也就是绑定到Observable监听方针
  2. Observable发送工作序列
  3. 工作触发后会推送到Observer进行监听

工作：

publicenumEvent<Element>{
///Nextelementisproduced.
casenext(Element)
///Sequenceterminatedwithanerror.
caseerror(Swift.Error)
///Sequencecompletedsuccessfully.
casecompleted
}

说明：

  • 工作有三种，通过枚举来存储
  • next：
    • 发送的信息会带着详细数据
    • 是一个关联值，发送的值是界说工作时传入的
  • error：
    • 带着错误信息
    • 间断Observable，不会再发出工作
  • completed：
    • 标明Observable间断，不会再发出工作

3、 基本完结

3.1 工作监听

3.1.1 触发工作

//1. 触发工作
var observable = Observable<Int>.create { observer in
    observer.onNext(1)
    observer.onCompleted()
    return Disposables.create()
}
// 等价于
observable = Observable.just(1)
observable = Observable.of(1)
observable = Observable.from([1])
var observable = Observable<Int>.create { observer in
    observer.onNext(1)
    observer.onNext(2)
    observer.onNext(3)
    observer.onCompleted()
    return Disposables.create()
}
// 等价于
observable = Observable.of(1, 2, 3)
observable = Observable.from([1, 2, 3])

说明：

  1. 在创立Observable的时分就可以通过闭包表达式来发送消息
  2. 这儿的onNext就是发送一次消息
  3. onCompleted()就是间断发送
  4. just()/of()/from()也是发送一次消息，参数就是发送的信息
    1. 但是他们发送后就会间断发送
    2. 因而他们就等价于上面的onNext()+onCompleted()
  5. of和from可以一次性发送多个消息，而just只能发送一次消息

3.1.2、订阅接收工作

//2. 订阅接收工作
observable.subscribe { event in
    print(event)
}.dispose()
observable.subscribe(onNext: {
    print("next", $0)
}, onError: {
    print("error", $0)
}, onCompleted: {
    print("completed")
}, onDisposed: {
    print("dispose")
}).dispose()

说明：

  • 此处进行监听工作
  • 通过订阅后才华监听到工作

3.1.3 吊销订阅

disposed：

observable.subscribe { event in
    print(event)
}.dispose()
  • 这儿是一次性订阅，当发送消息后就会吊销订阅

takeUtil：

observable
    .takeUtil(self.rx.deallocted)
    .map { "数值是：\($0)" }
    .bind(to: label.rx.text)
  • 此处表明当self生命周期结束后，订阅吊销
  • 所有的NSObject都会有rx

3.3 监听者

observer代码：

let observer = AnyObserver<Int>.init { event in
    switch event {
    case .next(let data):
        print(data)
    case .completed:
        print("completed")
    case .error(let error):
        print("error", error)
    }
}
Observable.just(1).describe(observer).dispose()

说明：

  • observer都通过AnyObserver完结，初始化时直接创立event的照应操作
  • 总共有三种监听样式

binder：

Observable.just(1).describe(observer).dispose()
let binder = Binder<String>(label) {label, value in
    label.text = value
}
observerable.just(1).map{ "数值是\($0)" }.subscribe(binder).dispose()
observerable.just(1).map{ "数值是\($0)" }.bind(to: binder).dispose()

说明：

  • binder也可以作为监听者，监听数据的改动。
  • 一同需求留意这儿监听方法有两种，他们的效果是彻底相同的，是等价的
  • 传入的label就是需求绑定的方针
  • 传入的value就是绑定的数据

3.3 时间监听

//时间监听
let observable = Observable<Int>.timer(.seconds(3),
                                       period: .seconds(1),
                                       scheduler: MainScheduler.instance)
observable.map { "数值是\($0)" }
.bind(to: label.rx.text)
.disposed(by: bag)

说明：

  1. 第一个参数是枚举值很好用，终究的一个参数是设置线程的
  2. Observable通过.bind绑定label的rx的text
  3. 可以通过map来修正值
  4. label.rx.text就是Observer
  5. disposed就表明不再接收订阅，当bag毁掉的时分就可以吊销订阅