RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

Subject：它既是Observable，又是observer。也就是既可以发送事件，也可以接收事件。

下面是四个子类PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的区别：

PublishSubject<Integer> source = PublishSubject.create();　　//PublicSubject：接收到订阅之后的所有数据。
// It will get 1, 2, 3, 4 and onComplete
source.subscribe(getFirstObserver());
source.onNext(1);
source.onNext(2);
source.onNext(3);
// It will get 4 and onComplete for second observer also.
source.subscribe(getSecondObserver());
source.onNext(4);
source.onComplete();

ReplaySubject<Integer> source = ReplaySubject.create();　　//ReplaySubject：接收到所有的数据，包括订阅之前的所有数据和订阅之后的所有数据。
// It will get 1, 2, 3, 4
source.subscribe(getFirstObserver());
source.onNext(1);
source.onNext(2);
source.onNext(3);
source.onNext(4);
source.onComplete();
// It will also get 1, 2, 3, 4 as we have used replay Subject
source.subscribe(getSecondObserver());

BehaviorSubject<Integer> source = BehaviorSubject.create();　　//BehaviorSubject：接收到订阅前的最后一条数据和订阅后的所有数据。
// It will get 1, 2, 3, 4 and onComplete
source.subscribe(getFirstObserver());
source.onNext(1);
source.onNext(2);
source.onNext(3);
// It will get 3(last emitted)and 4(subsequent item) and onComplete
source.subscribe(getSecondObserver());
source.onNext(4);
source.onComplete();

AsyncSubject<Integer> source = AsyncSubject.create();　　//AsyncSubject：不管在什么位置订阅，都只接接收到最后一条数据
// It will get only 4 and onComplete
source.subscribe(getFirstObserver());
source.onNext(1);
source.onNext(2);
source.onNext(3);
// It will also get only get 4 and onComplete
source.subscribe(getSecondObserver());
source.onNext(4);
source.onComplete();

文章转载：
RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解相关推荐

回过头来看对象的四种状态强软弱虚引用的理解
一.对象的四种引用状态描述在JDK1.2之后,Java对引用的概念进行了扩充,将引用分为强引用(Strong Reference).软引用(Soft Reference).弱引用(Weak Refe ...
MySQL ACID及四种隔离级别的解释
以下内容出自<高性能MySQL>第三版,了解事务的ACID及四种隔离级有助于我们更好的理解事务运作. 下面举一个银行应用是解释事务必要性的一个经典例子.假如一个银行的数据库有两张表:支票表 ...
java中的强软弱虚_详解Java的四种引用——强软弱虚，颠覆你的认知！
强软弱虚 java中的数据被类型分为了两类,它们分别是基本类型和引用类型.一般我们new出来的对象都属于引用类型的范畴.我们知道java是有垃圾回收机制的一种语言,根据垃圾回收时的策略,java将对于 ...
深入理解MySQL的四种隔离级别
深入理解MySQL的四种隔离级别[日期:2017-02-20] 来源:Linux社区作者:Linux [字体:大中小]什么是事务事务是应用程序中一系列严密的操作,所有操作必须成功完成,否则在每个 ...
RxJava之PublishSubject、BehaviorSubject、ReplaySubject和AsyncSubject
public class T2 {/*** subject 是一个神奇的对象,它可以是一个Observable同时也可以是一个Observer:它作为连接这两个世界的一座桥梁.* 一个主题可以订阅一个 ...
java 场景处理,最适合使用RxJava处理的四种场景
RxJava是异常热点的函数响应式编程库,在Android开辟中已经异常风行了,刚开端上手会有点难,但只要懂得了它,就再也回不去了:不应用RxJava写异步请求的话,就感到各类不爽. 本文不预备讲Rx ...
RxJava学习(四利用RxJava打造自己的RxBus)
前面说过Rxjava的功能很强大,不仅仅是实现链式的异步操作,它的功能很强大还可以通过RxBus实现EventBus的消息/事件传递功能,我们来看看 RxBus 1 package com.exam ...
【Rxjs】 - 解析四种主题Subject
原文地址: https://segmentfault.com/a/1190000012669794 引言开发ngx(angular 2+)应用时,基本上到处都会用到rxjs来处理异步请求,事件调用等 ...
datatable的数据进行组内排序_Spark实现分组Top-k排序的四种方案（scala语言）
Spark中实现分组排序(取Top-k)的四种方法. 以求每个学科最受欢迎的老师为例,假设学科下每个老师的主页访问量的多少代表该老师的受欢迎程度. 截取log日志文件中的网址数据的格式为: 数据格式: ...

RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

RxJava的四种Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解相关推荐

最新文章

热门文章