RxJava:Subject

他是一个桥梁

A Subject is a sort of bridge or proxy that is available in some implementations of ReactiveX that acts both as an observer and as an Observable.

扮演两种角色

两种行为

  1. Because it is an observer, it can subscribe to one or more Observables,
  2. and because it is an Observable, it can pass through the items it observes by reemitting them, and it can also emit new items.

1. AsyncSubject

特色:

  1. 在被观察者的提交数据完毕的时候,它提交(被观察者提交的)最后一个数据。

    Paste_Image.png

  2. 若被观察者出现了错误,它直接发射错误。

Paste_Image.png

2.BehaviorSubject

特色:

  1. 当一个观察者订阅它时,它将会提交给观察者最近的一个发射的数据。


    Paste_Image.png
  2. 若这个被观察者出现错误时,这时,当一个观察者订阅它时,这个被观察者会发射一个错误给它。

Paste_Image.png

3. PublishSubject

特色:当订阅者订阅后,被观察者发射了什么,就发射给订阅者什么。


Paste_Image.png
Paste_Image.png

4. ReplaySubject

replay 是重播的意思。

特色:

  1. 只要有订阅者订阅,它就会把被观察者所提交过的所有数据 都发射给订阅者。
  2. 重播 肯定缓存了数据(可设置缓存的数量,或时间间隔)
Paste_Image.png

注意
当把它作为被观察者的时候,不要在多个线程中调用 它的onNext。这会引起并发的问题。

5. SerializedSubject

他可以包装 subject,所以当多个线程来访问它的时候,它是安全的。

包装:

  mySafeSubject = new SerializedSubject( myUnsafeSubject );
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,083评论 19 139
  • 这篇文章写的内容是从资料上复制下来的。应该是RxJava的官方资料翻译过来的文件,忘记原出处了。 Subject ...
    re冷星阅读 461评论 0 2
  • 注:只包含标准包中的操作符,用于个人学习及备忘参考博客:http://blog.csdn.net/maplejaw...
    小白要超神阅读 2,252评论 2 8
  • 自己这次成绩并不算很好,主要输在两点:动情,还有气息。机关的演讲比赛难免形式,中规中矩居多。看取得名次好的人,主要...
    家有果宝阅读 320评论 2 0
  • 文|西风南浦 01 春节假期结束了,数以万计的年轻人又离开了家乡,为自己的梦想打拼,虽然不管你从事什么职业,父母们...
    西风南浦阅读 2,512评论 32 66