StateFlow初步探究

flow是如何工作的

stateflow是建立在flow的基础上的,要理解stateflow,首先需要对flow有一定的了解,其实flow的原理很简单,不过是建立在了协程的基础上,假设没有协程,实际上flow就是用一个回调(FlowCollector)来进行工作的,加上了协程之后,由于协程支持中断和恢复,让flow可以匹配发送端和接受端的速度,毕竟如果不匹配的话就可以直接中断嘛,

用伪代码来表示flow的流程

flow {
    emit(something) // 上游
}.collect {
    print(it) // 下游
}

// flow函数块的签名如下
flow(suspend block: FlowCollector<T>.() -> Unit): Flow<T> = {
    return object:Flow<T> {
        suspend fun collect(FlowCollector<T> collector) {
            collector.block()
        }
  }
}

可以看到我们调用的emit函数实际上就是collect方法体的代码,也就是说流的数据是由订阅驱动的,这也是为什么我们把flow叫做冷流,当然实际代码为了满足流的约束,创建的并非简单的匿名类,而是通过SafeFlow 和SafeCollector 满足流的约束,

  1. flow是通过flowOn来进行上游数据发送实际线程进行切换的,在调用emit时我们不应该自己去切换上下文
  2. 上游取消了应该能够联动下游
  3. 下游取消了也需要能够联动上游

上游取消了能够联动下游,对于在同一个协程的flow来说,这是天然可以做到的事情,上游取消了,下游的代码自然就不执行了,对于不在同一个协程的flow呢?,通过在collect的时候使用coroutineScope 创建一个新的协程和作用域,如果collect所在的方法的协程被取消了,那么下游和上游都能够取消,

SafeCollector所做的一件事就是如果下游触发异常了,那么上游后续发送的数据下游都不会在接收了,原理这里后续再分析

flow是如何切换线程的

通过flowOn指定Dispatcher,然后为上游创建一个Channel和运行在新Dispatcher的协程,订阅上游的数据,并且通过Channel下发往下游,下游运行在collect的协程,通过订阅channel的数据,从而达到线程切换的目的,flowOn可以多次指定

StateFlow

StateFlow是建立在flow基础上,可以通过将最新的状态推送到订阅者,原本的flow是封闭的,不支持对外去更改值,然后触发更新,本质上StateFlow维护了一个观察者模式,当State有更新的时候将这个更新传递给所有观察者,但因为协程的存在,需要对所有观察者维护额外的状态,比如当将一个值传递给下游协程时,下游协程可以被中断,直到新值传入再唤起下游的协程,这里StateFlow是通过内部的Slot再维护多余的状态来做到这件事的,

Slot的状态有 null → NONE → PENDING or 下游Continuation → 传递新值

StateFlow 只有当数据更新时才会通知下流,这避免了LiveData的一些问题

StateFlow和SharedFlow有何不同

SharedFlow支持n个数据的重放,这个n是可配置的,StateFlow永远只保存最新的数据

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

推荐阅读更多精彩内容