- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章RxSwift学习教程之基础篇由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
前言 。
我们在 iOS 开发过程中,几乎无时无刻都要面对异步事件的处理。例如,按键点击、数据保存、、音频后台播放、交互动画展示。这些事件并不具备特定时序性,甚至它们可能同时发生.
虽然 Apple 提供了通知、代理、GCD、闭包等异步机制,但是这些机制缺乏一个统一的抽象表述。另外,这些机制在处理共享的可变数据或状态时不够清晰简练。当然,这并不是说编写优雅的异步代码不现实。毕竟与其他平台相比 iOS 的异步机制还是很强大的.
幸运的是,我们能够通过 RxSwift 优雅的处理异步代码.
至于 RxSwift 的优势以及为什么要使用它,详见文档。这里就不废话了.
RxSwift 简介 。
其实响应式编程并不是一个什么新的概念,只不过是最近几年受到了开发者更多的关注。它最早由巨硬提出,主要的目的是为了应对复杂的 UI 异步事件和应用实时响应。社区中也已经有了各种语言版本的响应式编程实现,包括:RxJS、RxKotlin、Rx.NET、RxScala、RxSwift。这些类库仅仅只是实现方式存在差异,所以开发者在讨论应用逻辑时不会存在沟通障碍.
RxSwift 作为 Swift 语言的响应式编程实现,它在传统的命令式编程和纯函数式编程中找到了一个很好的平衡点。通过使用不可变代码定义异步处理输入,RxSwift 以一种确定可组合的形式对事件做出响应.
总的来说,RxSwift 有三个主要构成部分:Observable、Operator、Scheduler 。下面我们就来一一介绍.
Observable 。
Observable<T> 类可以说是 RxSwift 整个框架的基石。它能异步的触发一系列事件流并携带不可更改的状态变量。简单来说就是:它能让某个类的实例在一段时间内实现对另一个实例对象值的观察。例如:观察者可以捕获对所有可观察对象触发的事件,从而实现 UI 的实时更新或者是数据的实时处理.
其中 Observable<T> 类遵循了 ObservableType 协议。另外,Observable 对象所能触发的事件只有以下三种:
对于一个可观察的整型变量来说,异步环境下它所触发的事件可以在时间线上被描绘成这样一个事件序列:
另外,我们可以对这三类事件进行组合从而实现更为复杂的业务逻辑。与此同时,我们还可以使用该机制轻松实现代码解耦和多个对象间数据传递,无需编写代理或者闭包代码.
这里,我们还有一点值得注意。那就是可观察序列其实有两种类型.
有限观察序列( Finite observable sequences ) 。
该序列是指那些最后会以 completed 或者 error 事件终极生命周期的可观察对象。最典型的例子就是,通过 API 进行网络请求:
下面是一个文件下载请求的 Rx 范式的代码:
1
2
3
4
5
6
7
|
API.download(file:
"http://www..."
)
.subscribe( onNext: { data in
append data to temporary file },
onError: { error in
display error to user },
onCompleted: {
use downloaded file })
|
这段代码中 API.download (file:) 函数会创建一个 Observable<Data> 实例对象,并且在整个数据接收过程中会不断的触发 next 事件。然后,我们在 next 事件中会将这些片段数据保存到临时文件中。如果此过程出现错误的话,我们会将错误信息展示给用户。如果一切顺利我们会将临时文件保存到设备中。最后在下载完成后,我们可以在 completed 进行下一步的逻辑处理.
无限观察序列( Infinite observable sequences ) 。
与网络任务不同的是,UI 以及交互事件是无限观察序列。它们并不存在一个明确的生命周期终结点。例如,针对可能的设备方向旋转,我们需要实时进行布局修改。而设备的方向旋转本身是随机发生的并且与应用本身具有同样的生命周期。因此 Rx 也需要一种机制支持这种无限观察序列.
针对这种情况,在 RxSwift 中我们可以通过以下代码来应对:
1
2
3
4
5
6
7
8
|
UIDevice.rx.orientation.subscribe(onNext: { current in
switch
current {
case
.landscape:
re-arrange UI
for
landscape
case
.portrait:
re-arrange UI
for
portrait
}
})
|
操作符 。
ObservableType 以及 Observable 类的实现中都包含大量的异步处理方法,这些方法也被称为操作符。由于这些操作符只是进行异步输入处理并产生对应输出,所以它并不会对应用产生多余的副作用。另外,因为操作符之间的高度解耦所以我们很容易对它进行组合以期实现复杂的功能.
例如,对于上面的设备方向旋转,我们可以对所有的情况进行过滤然后对部分值进行进一步处理.
1
2
3
4
5
6
7
8
9
10
|
UIDevice.rx.orientation
.filter { value in
return
value != .landscape
}
.map { _ in
return
"Portrait is the best!"
}
.subscribe( onNext: { string in
showAlert(text: string)
})
|
上面的代码中,我们首先会将所有 .landscape 方向过滤掉不做任何处理。然后,我们再将剩下的 portrait 转化为字符串 Portrait is the best! 。整个处理流程大致如下:
这种函数式的操作符让我们可以灵活的组合出更强大的功能.
Scheduler 。
Schedulers 是一个与 GCD 相对应的概念,只不过前者使用起来更为方便。RxSwift 中预定义的 Schedulers 足够开发者应对绝大多数的编程场景.
例如,我们可以使用串型序列 SerialDispatchQueueScheduler 来处理 next 事件,通过 ConcurrentDispatchQueueScheduler 运行并行文件下载任务,通过 OperationQueueScheduler 运行一个 NSOperationQueue 操作队列。甚至你可以在同一个观察对象的不同任务中使用不同的 Schedulers 类型,如下图:
我们将左侧的任务用不同的颜色加以区分,然后在右侧任务被拆分为不同的步骤并且放在不同 Schedulers 中。例如,network subscription 任务就被拆分为三个步骤并依次放入了 Custom NSOperation Scheduler 、Background Concurrent Scheduler、Main Thred Serial Scheduler .
补充 。
值得注意的是, RxSwift 并没有对客户端的应用架构作出硬性规定。这意味着,我们可以在已有项目中引入 RxSwift 进行响应式编程实践。当然已有框架中必定存在一个最适合 RxSwift 的,而它就是 MVVM。因为在 MVVM 中我们可以将 VM 中的部分属性直接与 UI 进行绑定.
另外,对于 iOS 编程来说仅仅有 RxSwift 是远远不够的。RxSwift 只是 Swift 语言的响应式实现,我们还需要一种 Cocoa 层面的实现。好在这里存在 RxCocoa 作为 UIKit 的响应式补充。前面设备方向代码 UIDevice.rx.orientation 就是 RxCocoa 的应用 .
总结 。
作为系列开篇,本文介绍了 RxSwift 的一些基本理念和构成,更多相关的内容将会在后面带来.
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对我的支持.
原文链接:https://bignerdcoding.com/archives/50.html 。
最后此篇关于RxSwift学习教程之基础篇的文章就讲到这里了,如果你想了解更多关于RxSwift学习教程之基础篇的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我尝试使用 RxSwift 作为依赖项创建一个名为 MyLib 的库,它使用 cocoapod 命令 pod lib create。但是,以下代码不起作用。 import UIKit import M
我是 RxSwift 的新手。很新。通常要在没有 Rx 的情况下链接你,你将下一个函数放在一个完成闭包中。我的同事告诉我改用 flatmap 或我们的 concatmap 版本,但从未给我一个例子。有
我创建了一个使用 RxSwift、RxCocoa 和其他第三方框架的自定义框架。自定义框架正确编译,但当我添加到应用程序时,它崩溃并出现以下错误: dyld: Library not loaded:
我会尽可能简短:我们启动了完整的 RxSwift 应用程序,但我们的协调员开始不知所措,难以维护和扩展,因此我们正在重新设计他们以不使用 RxSwift,现在我们不知道如何使用它们以及保存它们的位置。
我正在使用 RxSwift 和 MVVM 实现一个简单的地址 UITableView。我像这样在我的 View Controller 中创建了一个绑定(bind)。 viewModel.address
ReactiveX.io documentation使用 AnonymousDisposable,它在 RxSwift 2.x 中,但在 RxSwift 3.0 中是一个未解析的标识符。我应该改用什么
我有一个应用程序使用 MVP与 Coordinator图案。 当子协调器发送事件时,我希望我的 AppCoordinator递归调用一个方法,根据一些 SessionState 选择下一个协调器. 该
上下文:我的团队正在开始一个新的中型 Swift 项目(大约 20 MM),我正在考虑在 RxSwift 中开发它.我的一位经理怀疑,他曾经在 上的调试方面有过不好的经历。响应式(Reactive)编
嘿,我在 HackingWithSwift 教程中学到了如何使用 Combine 发出链接的网络请求(请参阅下面的代码)。现在我将使用 RXSwift 构建相同的逻辑,但我不知道如何像在 Combin
我正在尝试进行几个 API 调用并填充领域数据库。 一切正常。但是,当我尝试运行 performSegue()在 subscribe()方法引发异常,通知我不能在后台线程上执行此操作,这是完全合理的。
假设我有 Int 数组: var items = [1, 2, 3, 4, 5] 以及一个接受 Int 参数并基于它发送网络请求的函数: func sendRequest(argument: Int
我有一个文本字段,它有 2 个验证规则:最小数量的字符和字母数字字符。 我希望能够向用户展示他在错误标签中做错了什么,但问题是,如果我将文本字段绑定(bind)到两个规则,它可能会令人毛骨悚然,因为一
我试图在选择表行时在后台执行复杂的计算,但它卡住了 UI。请查看我的代码并告诉我可能有什么问题。 tableView.rx .modelSelected(Sring.self) .fl
我正在尝试构建一个计时器,该计时器从15秒开始,递减计数到0。 事情是,我想根据事件将计时器更新2秒。 到目前为止,这是我尝试做的事情: struct ViewModel { struct I
我正在使用该领域作为后端。使用RxSwift,我可以在DB表中观察到某些列(它跟踪未决状态)。得到事件后,我切换到另一个Serial计划表,以将列的值设置为flatMap块中的Progress状态(返
我对响应式(Reactive)编程很陌生,所以我仍然很难理解它是如何工作的。 我正在尝试做的事情:当用户点击 signUpButton (signUpTrigger) 时,会触发多个 observab
以下是与问题39类似的示例:http://reactivex.io/learnrx/ 我正在尝试将方法调用search(query: String)转换为这些调用的序列。 他们通过创建一个Variab
我有两个 Single 值,它们包含同一对象的数组。我想合并它们并应用 map 并将它们作为单个返回。可能吗? 所以我有这个: func fetchTripList(type: TripType) -
使用 RxSwift,假设我有一个包含整数可观察值的 A 类 class A: { let count: Observable } 以及 A 的可观察对象集合 let data: Observ
我想转换一个我已经完全接收的 ViewModel。该应用程序计算算术表达式。 ViewModel 有两个字符串,一个带有“逻辑”符号,将发送到表达式求值器以获取结果,另一个带有其他符号的“演示”字符串
我是一名优秀的程序员,十分优秀!