Swift知识点---RxSwift学习

2024-09-07 17:12
文章标签 学习 知识点 swift rxswift

本文主要是介绍Swift知识点---RxSwift学习，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. 什么是RxSwift

RxSwift是Swift函数响应式编程的一个开源库，由Github的ReactiveX组织开发、维护

RxSwift的目的是：让数据/事件流 和 异步任务能够更方便的序列化处理，能够使用Swift进行响应式编程

RxSwift本质上还是观察者模式，并且是一个响应式的，并且可以序列化的

观察者模式

观察者模式包括：KVO、通知等

爸爸妈妈照看观察宝宝
其中，宝贝就是被观察者
爸爸妈妈就是观察者，或者说是订阅者
只要被观察者（宝宝）发出来某些事件，比如哭声、叫声，则被称为事件，通知到订阅者
此时，订阅者就可以做响应的工作

RxSwift做了什么？

RxSwift把我们程序中的每一个操作都看成一个事件
比如一个TextField中的文本改变、一个按钮被点击、一个网络请求结束等
每一个事件源就可以看成一个管道，也就是sequence

比如，TextField，当我们改变里面的文本的时候，这个TextField就会不断的发出事件
从他的sequence中不断流出，我们只需要监听这个sequence，每流出一个事件就做相应的处理

同理，Button也是一个sequence，每点击一次就流出一个事件

理解Observable和Observer

在这里插入图片描述

2. RxSwift简单体验

  • RxSwift监听按钮的点击
  • RxSwift监听UITextField的文字改变
  • RxSwift改变Label中的文字
  • RxSwift监听对象属性改变
  • RxSwift监听UIScrollView的滚动
  • …
//导入RxSwift
import RxSwift
import RxCocoa

按钮监听

原始方法：
button.addTarget(self, action: #selector(button1Click), for: .touchUpInside)

使用RxSwift的方法：

self.button.rx.tap.subscribe { (event: Event<Void>) inprint(event)
}

上述方法会有一个标黄的警告：Result of call to ‘subscribe’ is unused
修改方法：

private lazy var disposeBag: DisposeBag = DisposeBag()self.button.rx.tap.subscribe { (event: Event<Void>) inprint(event)
}.disposed(by: disposeBag)```

监听UITextField文字的改变

方法一：传统方法

略

方法二：
self.view.addSubview(self.textField)
self.textField.frame = CGRect(x: 200, y: 300, width: 100, height: 40)
self.textField.rx.text.subscribe { (event: Event<String?>) inprint(event.element)//获取信息
}.disposed(by: disposeBag)

这种方法，获取的event有两个Optional包裹着，使用起来不方便

方法三：
self.textField.rx.text.subscribe { (myString: String?) inprint(myString)//获取的是Optional类型
} onError: { error inprint(error)
} onCompleted: {print("onCompleted")
} onDisposed: {print("onDisposed")
}.disposed(by: disposeBag)

以上可以简化：

self.textField.rx.text.subscribe { (myString: String?) inprint(myString)//获取的是Optional类型
}.disposed(by: disposeBag)

监听Label中的文字

UITextField文字输入，然后Label显示输入的文字

方法一：
self.textField.rx.text.subscribe { (myString: String?) inprint(myString)self.myTitleLabel.text = myString
}.disposed(by: disposeBag)self.view.addSubview(myTitleLabel)
myTitleLabel.frame = CGRect(x: 100, y: 210, width: 200, height: 40)
方法二：
self.textField.rx.text.bind(to: myTitleLabel.rx.text).disposed(by: disposeBag)self.view.addSubview(myTitleLabel)
myTitleLabel.frame = CGRect(x: 100, y: 210, width: 200, height: 40)

RxSwift的KVO

self.view.addSubview(myTitleLabel)
myTitleLabel.frame = CGRect(x: 100, y: 210, width: 200, height: 40)myTitleLabel.rx.observe(String.self, "text").subscribe { (str: String?) inprint(str)
}.disposed(by: disposeBag)

RxSwift监听UIScrollView的滚动

self.view.addSubview(scrollView)
scrollView.frame = CGRect(x: 100, y: 280, width: 200, height: 150)
scrollView.rx.contentOffset.subscribe { (point: CGPoint) inprint(point)
}.disposed(by: disposeBag)

3. RxSwift常见操作

Never、Empty、Just、Of、From、Create、Range、RepeatElement

  • Never，什么都不执行
///never，啥事没有
let observableNever = Observable<String>.never()
observableNever.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)
  • Empty创建一个空的sequence，只能发出一个completed事件
 //只执行completed
let observableEmpty = Observable<String>.empty()
observableEmpty.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)打印结果：        
completed
  • Just是创建一个sequence，只能发出一种特定的事件，并且能正常结束

也就是，特定事件可以监听，complete事件可以监听

///Just：只执行特定类型+complete
let observableJust = Observable.just(123)//Int类型
observableJust.subscribe { (event: Event<Int>) in//Event<Int>相对应print(event)
}.disposed(by: disposeBag)打印结果：     
next(123)
completed
  • Of可以执行特定类型+complete
  • 创建一个sequence，可以发出多个事件信号
///Of: 可以执行特定类型多个事件+complete
let observableOf = Observable.of("1", "2", "3", "6")
observableOf.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)打印结果：          
next(1)
next(2)
next(3)
next(6)
completed
  • From从数组中创建sequence
///From: 可以执行数组+complete
let observableFrom = Observable.from(["123", "234", "345"])
observableFrom.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)打印结果：
next(123)
next(234)
next(345)
completed
  • Create可以自定义可观察的sequence
  • Create操作符传入一个观察者observer，然后调用observer的onNext，onCompleted和onError方法，返回一个可观察的observable序列
///Create: 可以自定义观察事件+complete
let observableCreate = createObservableFunc()
observableCreate.subscribe { (event: Event<Any>) inprint(event)
}.disposed(by: disposeBag)///创建自定义的createObservable
private func createObservableFunc() -> Observable<Any> {return Observable.create { (observer: AnyObserver<Any>) inobserver.onNext("123")observer.onNext("321")//注意：Disposables，带sreturn Disposables.create()}
}
打印结果：
next(123)
next(321)

如果想要completed，则需要加上：observer.onCompleted()

  • Range创建一个sequence，会发出这个范围中的从开始到结束的所有事件
///Range: 可以执行某个范围内的
let observableRange = Observable.range(start: 3, count: 3)
observableRange.subscribe { (event: Event<Int>) inprint(event)
}.disposed(by: disposeBag)打印结果：
next(3)
next(4)
next(5)
completed
  • RepeatElement重复执行某个事件
///RepeatElement: 重复执行某个事件
let observableRepeatElement = Observable.repeatElement("2")
observableRepeatElement.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)

执行以上代码，恭喜你，程序干崩溃了= =

可以加上take(count)：

///RepeatElement: 重复执行某个事件
let observableRepeatElement = Observable.repeatElement("2")
observableRepeatElement.take(3).subscribe { (event: Event<String>) inprint(event)}.disposed(by: disposeBag)打印结果：
next(2)
next(2)
next(2)
completed

4. RxSwift中Subjects

Subjects是什么？

Subject是Observable和Observer之间的桥梁
一个Subject既是一个Observable，也是一个Observer
即可以监听事件，也可以发出事件

Observable：监听事件
Observer：发出事件

PublishSubject、ReplaySubject、BehaviorSubject、BehaviorRelay

PublishSubject

当订阅PublishSubject的时候，只能接收订阅他之后发生的事件
subject.onNext()发出onNext事件，对应的还有OnError()和onCompleted()事件

let publishSub = PublishSubject<String>()
//不接收
publishSub.onNext("0")//订阅事件
publishSub.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)//只能接收订阅后的事件
publishSub.onNext("1")
publishSub.onNext("2")
publishSub.onNext("3")
publishSub.onCompleted()打印结果：
next(1)
next(2)
next(3)
completed

ReplaySubject

当你订阅ReplaySubject的时候，你可以接收到订阅他之后的事件
但也可以接受订阅他之前发出的事件，接受前面几个事件，取决与bufferSize的大小

//bufferSize决定订阅前接收几个。订阅后的都可以接收到
let replaySbu = ReplaySubject<String>.create(bufferSize: 2)
replaySbu.onNext("1-0")
replaySbu.onNext("1-1")
replaySbu.onNext("1-2")
//订阅事件
replaySbu.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)
replaySbu.onNext("1-3")
replaySbu.onNext("1-4")
replaySbu.onNext("1-5")
replaySbu.onCompleted()打印结果：
next(1-1)
next(1-2)
next(1-3)
next(1-4)
next(1-5)
completed

BehaviorSubject

BehaviorSubject会接受到订阅之前的最后一个事件

//behaviorSbu接收订阅前最后一个。订阅后的都可以接收到
let behaviorSbu = BehaviorSubject(value: "1")
behaviorSbu.onNext("2-0")
behaviorSbu.onNext("2-1")
behaviorSbu.onNext("2-2")
//订阅事件
behaviorSbu.subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)
behaviorSbu.onNext("2-3")
behaviorSbu.onNext("2-4")
behaviorSbu.onNext("2-5")
behaviorSbu.onCompleted()打印结果：
next(2-2)
next(2-3)
next(2-4)
next(2-5)
completed

BehaviorRelay

behaviorRelay是BehaviorSubject的一个包装箱
使用的时候，需要调用asObservable()拆箱，里面的value是一个BehaviorSubject
如果Variable准备发出事件，不需要onNext这种方式，而是直接修改对象的value即可

let behaviorRelay = BehaviorRelay(value: "3-1")
behaviorRelay.accept("3-2")
behaviorRelay.accept("3-3")
behaviorRelay.asObservable().subscribe { (event: Event<String>) inprint(event)
}.disposed(by: disposeBag)
behaviorRelay.accept("3-4")
behaviorRelay.accept("3-5")打印结果：
next(3-3)
next(3-4)
next(3-5)

RxSwift在UITableView的使用

方法一：

Model:

struct HeroModel: Codable {var name: Stringvar age: Stringvar description: Stringenum CodingKeys: String, CodingKey {case namecase agecase description = "describe"}
}

ViewModel:

class HeroViewModel {var herosObserrable: BehaviorRelay<[HeroModel]> = {var herosArray: [HeroModel] = [HeroModel]()guardlet path = Bundle.main.path(forResource: "RxSwiftData", ofType: "json"),let jsonData = try? Data(contentsOf: URL(fileURLWithPath: path))else {print("Error loading JSON file")return BehaviorRelay(value: [])}do {let decoder = JSONDecoder()herosArray = try decoder.decode([HeroModel].self, from: jsonData)for hero in herosArray {print(hero)}}catch {print("Error parsing JSON: \(error)")}return BehaviorRelay(value: herosArray)}()
}
extension ViewController {fileprivate func loadData(){//获取VMlet heroVM = HeroViewModel()//订阅VMheroVM.herosObserrable.asObservable().subscribe { (heros: [HeroModel]) inself.herosArray.removeAll()self.herosArray = herosself.myTableView.reloadData()}.disposed(by: disposeBag)}
}extension ViewController: UITableViewDelegate, UITableViewDataSource {func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int {return herosArray.count}func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {guard let cell = tableView.dequeueReusableCell(withIdentifier: "MyTableViewCell") as? MyTableViewCell else {print("Error: Could not dequeue cell as MyTableViewCell")return UITableViewCell()}cell.nameLabel.text = herosArray[indexPath.row].namecell.ageLabel.text = herosArray[indexPath.row].agecell.desLabel.text = herosArray[indexPath.row].descriptionreturn cell}
}private lazy var myTableView: UITableView = {let myTableView = UITableView()myTableView.delegate = selfmyTableView.dataSource = selfmyTableView.register(MyTableViewCell.self, forCellReuseIdentifier: "MyTableViewCell")return myTableView
}()

方法二：

Model、ViewModel同上

extension ViewController {fileprivate func loadData(){let heroVM = HeroViewModel()//直接在这，将监听的数据，直接赋值heroVM.herosObserrable.asObservable().bind(to: myTableView.rx.items(cellIdentifier: "MyTableViewCell", cellType: MyTableViewCell.self)){(row, hero, cell) incell.nameLabel.text = hero.namecell.ageLabel.text = hero.agecell.desLabel.text = hero.description}.disposed(by: disposeBag)}
}

这篇关于Swift知识点---RxSwift学习的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1145652。

相关文章

HarmonyOS学习(七)——UI（五）常用布局总结

HarmonyOS学习(七)——UI（五）常用布局总结

自适应布局 1.1、线性布局（LinearLayout） 通过线性容器Row和Column实现线性布局。Column容器内的子组件按照垂直方向排列，Row组件中的子组件按照水平方向排列。 属性说明space通过space参数设置主轴上子组件的间距，达到各子组件在排列上的等间距效果alignItems设置子组件在交叉轴上的对齐方式，且在各类尺寸屏幕上表现一致，其中交叉轴为垂直时，取值为Vert
阅读更多...
Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya（不是本人，claude AI）在社交媒体上分享了他在OpenAI学习到的15个Prompt撰写技巧。 以下是详细的内容： 提示精确化:在编写提示时,力求表达清晰准确。清楚地阐述任务需求和概念定义至关重要。例:不用"分析文本",而用"判断这段话的情感倾向:积极、消极还是中性"。 快速迭代:善于快速连续调整提示。熟练的提示工程师能够灵活地进行多轮优化。例:从"总结文章"到"用
阅读更多...
【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【课程链接】 AntV G6：深入图形与图形分组、自定义节点、节点动画（下）_哔哩哔哩_bilibili 本章十吾老师讲解了一个复杂的自定义节点中，应该怎样去计算和绘制图形，如何给一个图形制作不间断的动画，以及在鼠标事件之后产生动画。（有点难，需要好好理解） <!DOCTYPE html><html><head><meta charset="UTF-8"><title>06
阅读更多...
学习hash总结

学习hash总结

2014/1/29/   最近刚开始学hash，名字很陌生，但是hash的思想却很熟悉，以前早就做过此类的题，但是不知道这就是hash思想而已，说白了hash就是一个映射，往往灵活利用数组的下标来实现算法，hash的作用：1、判重；2、统计次数；
阅读更多...
基本知识点

基本知识点

1、c++的输入加上ios::sync_with_stdio(false);  等价于 c的输入，读取速度会加快（但是在字符串的题里面和容易出现问题） 2、lower_bound()和upper_bound() iterator lower_bound( const key_type &key ): 返回一个迭代器，指向键值>= key的第一个元素。 iterator upper_bou
阅读更多...
零基础学习Redis(10) -- zset类型命令使用

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合，内部除了存储元素外，还会存储一个score，存储在zset中的元素会按照score的大小升序排列，不同元素的score可以重复，score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]
阅读更多...
【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

引言 高斯过程（Gaussian Process，简称GP）是一种概率模型，用于描述一组随机变量的联合概率分布，其中任何一个有限维度的子集都具有高斯分布 文章目录 引言一、高斯过程1.1 基本定义1.1.1 随机过程1.1.2 高斯分布 1.2 高斯过程的特性1.2.1 联合高斯性1.2.2 均值函数1.2.3 协方差函数（或核函数） 1.3 核函数1.4 高斯过程回归（Gauss
阅读更多...
【学习笔记】 陈强-机器学习-Python-Ch15 人工神经网络（1）sklearn

【学习笔记】 陈强-机器学习-Python-Ch15 人工神经网络（1）sklearn

系列文章目录 监督学习：参数方法 【学习笔记】 陈强-机器学习-Python-Ch4 线性回归 【学习笔记】 陈强-机器学习-Python-Ch5 逻辑回归 【课后题练习】 陈强-机器学习-Python-Ch5 逻辑回归（SAheart.csv） 【学习笔记】 陈强-机器学习-Python-Ch6 多项逻辑回归 【学习笔记 及 课后题练习】 陈强-机器学习-Python-Ch7 判别分析 【学
阅读更多...
系统架构师考试学习笔记第三篇——架构设计高级知识（20）通信系统架构设计理论与实践

系统架构师考试学习笔记第三篇——架构设计高级知识（20）通信系统架构设计理论与实践

本章知识考点：         第20课时主要学习通信系统架构设计的理论和工作中的实践。根据新版考试大纲,本课时知识点会涉及案例分析题(25分),而在历年考试中,案例题对该部分内容的考查并不多,虽在综合知识选择题目中经常考查,但分值也不高。本课时内容侧重于对知识点的记忆和理解,按照以往的出题规律,通信系统架构设计基础知识点多来源于教材内的基础网络设备、网络架构和教材外最新时事热点技术。本课时知识
阅读更多...
线性代数|机器学习-P36在图中找聚类

线性代数|机器学习-P36在图中找聚类

文章目录 1. 常见图结构2. 谱聚类 感觉后面几节课的内容跨越太大，需要补充太多的知识点，教授讲得内容跨越较大，一般一节课的内容是书本上的一章节内容，所以看视频比较吃力，需要先预习课本内容后才能够很好的理解教授讲解的知识点。 1. 常见图结构 假设我们有如下图结构： Adjacency Matrix:行和列表示的是节点的位置，A[i,j]表示的第 i 个节点和第 j 个
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2