RxSwift之traits后篇:RxCocoa traits

这里是原文:Traits (formerly Units)
这一篇是整篇翻译的后半部分,建议先看看前半部分:RxSwift之traits前篇:RxSwift traits

RxCocoa traits


Driver

这是最复杂的trait,它的目标是提供一种简便的方式在UI层编写响应式代码,或者任何你想模拟驱动你的App的数据流的情况。

  • 不能抛出错误
  • 监听发生在主线程
  • 分享副作用(shareReplayLatestWhileConnected)
为什么命名为Driver

它的目标用例是作为驱动你的App的序列模型。
例如:

  • 由CoreData模型驱动UI
  • 使用其他UI元素(绑定)的值驱动UI

就像正常的操作系统驱动程序一样,假如一个序列抛出错误,你的应用程序就会停止响应用户操作。
那些元素在主线程被监听,这极其重要,因为UI元素和程序逻辑通常不是线程安全的。
此外,Driver建立了一个分享副作用的可观察序列。
例如:

实际使用的例子

这是一个典型的初学者例子:

let results = query.rx.text
    .throttle(0.3, scheduler: MainScheduler.instance)
    .flatMapLatest { query in
        fetchAutoCompleteItems(query)
    }

results
    .map { "\($0.count)" }
    .bind(to: resultCount.rx.text)
    .disposed(by: disposeBag)

results
    .bind(to: resultsTableView.rx.items(cellIdentifier: "Cell")) { (_, result, cell) in
        cell.textLabel?.text = "\(result)"
    }
    .disposed(by: disposeBag)```
以上代码的预期行为是:
* 节流用户输入
* 联系服务器并获取用户结果列表(每次查询一次)
* 绑定结果到两个UI元素:results table view和一个显示结果数字的label

那么,这个代码有什么问题呢?
* 如果`fetchAutoCompleteItems `可观察序列抛出错误(连接失败或者是解析错误),这个错误将会解绑所有元素,并且UI不会再响应新的查询。
* 如果`fetchAutoCompleteItems`在某个后台线程返回结果,这些结果将会从一个后台线程绑定到UI元素上,这将会导致不确定的崩溃。
* 结果被绑定到两个UI元素上,这就意味着,对于每个用户查询,都会建立两个HTTP请求,每个UI元素对应一个,这并不是预期的行为。

一个更为合适的代码版本如下:

let results = query.rx.text
.throttle(0.3, scheduler: MainScheduler.instance)
.flatMapLatest { query in
fetchAutoCompleteItems(query)
.observeOn(MainScheduler.instance) // results are returned on MainScheduler
.catchErrorJustReturn([]) // in the worst case, errors are handled
}
.shareReplay(1) // HTTP requests are shared and results replayed
// to all UI elements

results
.map { "($0.count)" }
.bind(to: resultCount.rx.text)
.disposed(by: disposeBag)

results
.bind(to: resultsTableView.rx.items(cellIdentifier: "Cell")) { (_, result, cell) in
cell.textLabel?.text = "(result)"
}
.disposed(by: disposeBag)```
确保所有这些要求在大型系统中被正确处理很有挑战性,但有一种简单的使用编译器和traits来证明这些要求得到满足的方法。
下面的代码看起来几乎一样:

let results = query.rx.text.asDriver()        // This converts a normal sequence into a `Driver` sequence.
    .throttle(0.3, scheduler: MainScheduler.instance)
    .flatMapLatest { query in
        fetchAutoCompleteItems(query)
            .asDriver(onErrorJustReturn: [])  // Builder just needs info about what to return in case of error.
    }

results
    .map { "\($0.count)" }
    .drive(resultCount.rx.text)               // If there is a `drive` method available instead of `bindTo`,
    .disposed(by: disposeBag)              // that means that the compiler has proven that all properties
                                              // are satisfied.
results
    .drive(resultsTableView.rx.items(cellIdentifier: "Cell")) { (_, result, cell) in
        cell.textLabel?.text = "\(result)"
    }
    .disposed(by: disposeBag)```
那么这里发生了什么?
第一个`asDriver`方法把trait`ControlProperty `转换成trait`Driver `。

query.rx.text.asDriver()```
注意没有任何特别的事情需要做。Driver拥有ControlProperty所有的属性,加上一些其他的。底层的可观察序列只是被封装成了一个Drivertrait,就是这样。

第二个变化是:

.asDriver(onErrorJustReturn: [])```
任何可观察序列都能被转化为`Driver`,只要它满足三个属性:
* 不能抛出错误
* 在主线程监听
* 分享副作用(`shareReplayLatestWhileConnected `)

那么如何确保这些属性得到满足呢?只使用标准的Rx操作符。
`asDriver(onErrorJustReturn: []) `和以下代码是等价的。

let safeSequence = xs
.observeOn(MainScheduler.instance) // observe events on main scheduler
.catchErrorJustReturn(onErrorJustReturn) // can't error out
.shareReplayLatestWhileConnected // side effects sharing
return Driver(raw: safeSequence) // wrap it up```
最后一件事是用drive代替bindTo
drive只在Driver特性里定义。这就意味着,如果你在某些代码里看到drive,那个可观察序列绝不会抛出错误,并且它在主线程监听,这对于绑定一个UI元素来说是安全的。

注意,然而理论上,别人仍然可以为ObservableType或者是一些其他接口定义一个drive方法来工作,因此为了更加安全,在绑定UI元素之前用let results: Driver<[Results]> = ...创建一个临时的定义是有必要的。然而,我们将留给读者来决定这是否是一个现实的方案。

ControlProperty / ControlEvent

  • 不能抛出错误
  • 订阅发生在主线程
  • 监听发生在主线程
  • 分享副作用
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,772评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,458评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,610评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,640评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,657评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,590评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,962评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,631评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,870评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,611评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,704评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,386评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,969评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,944评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,179评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,742评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,440评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,590评论 18 139
  • 亚历山大 · 亚历山德罗维奇 · 柳比歇夫(1890 年 4 月 5 日——1972 年 8 月 31 日),前苏...
    二石兄阅读 354评论 0 0
  • 郑姐谈起她女儿的时候,眼眶红了。 她说因为工作原因,把她那两岁多的宝贝女儿留在老家,让孩子的爷爷奶奶带。郑姐只是偶...
    云朵朵啊阅读 61,602评论 5 9
  • 朱妍这几天愁的紧。 杭州的雨一直下,洗的衣服一直潮着。 她做梦都想来个大晴天,一股脑儿的都给杀杀菌。被单也该洗了。...
    唐小茴阅读 256评论 2 0