Swift基础语法文章汇总

本文主要认识RxSwift的原理，以及简单使用，实现监听响应操作

主要内容：

1. 响应式编程的认识
2. RxSwift的原理认识
3. RxSwift的简单使用

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进行监听

事件：

public enum Event<Element> {
/// Next element is produced.
case next(Element)

/// Sequence terminated with an error.
case error(Swift.Error)

/// Sequence completed successfully.
case completed
}

说明：

• 事件有三种，通过枚举来存储
• 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销毁的时候就可以取消订阅