如何使用主题(AsyncSubject，BehaviorSubject...)像RxJava1那样在RxJava2中吗？

在RxJava2中，可以使用Subject类来实现类似RxJava1中的主题（Subject）功能。Subject是一种特殊的Observable，它既可以充当数据的生产者，也可以充当数据的消费者。

在RxJava2中，有以下几种Subject类可以使用：

PublishSubject：它只会将在订阅之后产生的数据发送给观察者。如果在订阅之前已经有数据产生，观察者将无法接收到这些数据。
BehaviorSubject：它会将订阅之前最近产生的一个数据发送给观察者，然后继续发送订阅之后产生的数据。
ReplaySubject：它会将所有产生的数据都发送给观察者，无论观察者何时订阅。
AsyncSubject：它只会在Observable完成之后，发送最后一个数据给观察者。如果Observable没有完成，观察者将无法接收到任何数据。

使用这些Subject类可以实现类似RxJava1中的主题功能。例如，使用BehaviorSubject可以在订阅之前获取最近的一个数据，使用AsyncSubject可以在Observable完成之后获取最后一个数据。

以下是腾讯云相关产品和产品介绍链接地址：

腾讯云函数计算（云原生）：https://cloud.tencent.com/product/scf
腾讯云数据库（数据库）：https://cloud.tencent.com/product/cdb
腾讯云服务器（服务器运维）：https://cloud.tencent.com/product/cvm
腾讯云人工智能（人工智能）：https://cloud.tencent.com/product/ai
腾讯云物联网（物联网）：https://cloud.tencent.com/product/iotexplorer
腾讯云移动开发（移动开发）：https://cloud.tencent.com/product/mad
腾讯云对象存储（存储）：https://cloud.tencent.com/product/cos
腾讯云区块链（区块链）：https://cloud.tencent.com/product/baas
腾讯云视频处理（音视频、多媒体处理）：https://cloud.tencent.com/product/vod
腾讯云网络安全（网络安全）：https://cloud.tencent.com/product/ddos

相关·内容

Rxjava概念初识与学习路径推荐

RxJava是使用Java实现的响应式编程库，RxJava即 Reactive Extensions Java。...目前有两个版本RxJava1和RxJava2,推荐使用RxJava2,RxJava1已经停止支持了 ReactiveX即Reactive Extensions，它通过可观测的序列，实现了组合异步和事件驱动...RxJava的一些API介绍创建Observable的基本方式，可以先了解最简单的just操作了解什么是Hot Observable，什么是 Cold Observable，以及如何将...相当于自己产生数据自己再消费 PublishSubject获取订阅时候的数据 BehaviourSubject可以获取订阅之前的1个数据 ReplaySubject能获取订阅前已经产生的所有数据 AsyncSubject...只获取最后一个数据 RxJava1中部分实例的实现 User user = new User(); user.setAge(1); Observable.just(user).subscribe(new

5622 0

RxJava1 升级到 RxJava2 所踩过的坑

RxJava2 RxJava2 发布已经有一段时间了，是对 RxJava 的一次重大的升级，由于我的一个库cv4j使用了 RxJava2 来尝鲜，但是 RxJava2 跟 RxJava1 是不能同时存在于一个项目中的...RxJava1 跟 RxJava2 不能共存如果，在同一个module中同时使用RxJava1和RxJava2，类似如下： compile 'io.reactivex.rxjava2:rxandroid...Rxjava1和Rxjava2无法共存.jpeg 同理，在 App 中如果使用了 Rxjava2，但是某个第三方的 library 还在使用 Rxjava1 也会遇到同样的错误。...所以在 RxJava2 中 Observable 不再支持 backpressure ，而使用新增的 Flowable 来支持 backpressure 。...对于老手，RxJava2 还是使用原来的思想，区别不大，从 RxJava1 迁移到 Rxjava2 也花不了多少工夫。

1.4K3 0

给初学者的RxJava2.0教程(一)

作者博客 http://www.jianshu.com/u/c50b715ccaeb 前言上个月RxJava2正式版发布了，但目前国内的资料还比较少，以前使用过RxJava1只需要看看更新文档就知道怎么使用了...我先回答这个问题：学习RxJava2需要先学习RxJava1吗？这个问题就像论坛经常问学Java前需要先学习C语言吗，这里就不引战了！（PHP是世界上最好的语言！！）...答案明显不是，如果你以前学过RxJava1，那么对于RxJava2只需要看看更新了哪些东西就行了，其最核心的思想并没有变化，如果你没学过RxJava1，没有关系，直接学习RxJava2。...所以作为一个RxJava2的教程，本文中所有的名词都属于RxJava2中，并不涉及RxJava1。...要在Android中使用RxJava2, 先添加Gradle配置: 正题在开始学习之前，先来介绍点原理性的东西。

8755 0

Carson带你学Android：RxJava2.0到底更新了什么？

非常类似同时，由于RxJava 2.0 跟 RxJava 1.0 不能共存在1个项目中，所以假如你在使用RxJava 1.0需要升级到RxJava 2.0，则需要做一些转变。...与 RxJava1 不能共存，即依赖不能同时存在 2....增加被观察者的新实现：Flowable 由于 RxJava 1.0 中的被观察者Observable不能很好地支持背压（Backpressure）所以，在 RxJava 2.0 中增加了被观察者的新实现...简化订阅方法对于简化订阅的方式， RxJava 1 主要采用 ActionX接口 & FuncX接口在 RxJava 2 中，主要是对这一系列接口的名字按照Java8的命名规则进行了修改，而使用方法不变...使用建议对于学习 & 在项目中使用RxJava的版本选择，我给出以下建议： 8. 总结本文主要讲解了RxJava 2.0相对于 RxJava 1.0的变动

4651 0

Rxjava2最全面的解析

给正在使用 RxJava2但仍然心存疑惑的人一些更深入的解析 3.给想从RxJava1替换成RxJava2的人给出直接的对比。...RxJava1与RxJava2的区别说到区别，可能有的小伙伴会问，我没看过rxjava1。可以直接看rxjava2么。...主要是如下几个方面：空指针问题这应该是一个很大的变化，用过rxjava1的人都知道，我们可以在发射事件的时候传入NULL。但这在rxjava2中是不存在的。不信你试试？...Function相关的在rxjava1中，我们有各种Func1，Func2......，但在rxjava2中只有Function了。依旧记得看凯哥的文章的时候把我整蒙了。...我们知道在Rxjava1中Observable对backpressure是支持的。但在Rxjava2中Observable取消了对backpressure的支持。

2.3K10 0

（含使用建议）

API 及方法有很大的区别但 RxJava 2.0 的使用思路和 RxJava 1.0 非常类似同时，由于RxJava 2.0 跟 RxJava 1.0 不能共存在1个项目中，所以假如你在使用...与 RxJava1 不能共存，即依赖不能同时存在 ---- 2....增加被观察者的新实现：Flowable 由于 RxJava 1.0 中的被观察者Observable不能很好地支持背压（Backpressure）所以，在 RxJava 2.0 中增加了被观察者的新实现...简化订阅方法对于简化订阅的方式， RxJava 1 主要采用 ActionX接口 & FuncX接口在 RxJava 2 中，主要是对这一系列接口的名字按照Java8的命名规则进行了修改，而使用方法不变...使用建议对于学习 & 在项目中使用RxJava的版本选择，我给出以下建议： ? ---- 8.

9923 0

彻底搞懂RxJS中的Subjects

任何新订户将被添加到主题在内部保留的订户列表中，并且同时将获得与其他订户相同的值。...如果我们改编前面的示例，这意味着第二个观察者在订阅时收到值2，然后像第一个观察者一样接收之后的所有其他值。...AsyncSubject 使用AsyncSubjects，在主题完成之前，观察者实际上什么也没收到。...我们必须完成主题。如果不这样做，我们的观察者将一无所获。在AsyncSubject完成后订阅的任何观察者将收到相同的值。...最后自己尝试这些示例并对其进行修改，以了解其如何影响结果。对RxJS主题的深入了解将有助于我们在响应式编程方面编写更具可读性和更高效的代码。

2.6K2 0

RxJava系列番外篇：一个RxJava解决复杂业务逻辑的案例

之前写过一系列RxJava1的文章，也承诺过会尽快有RxJava2的介绍。无奈实际项目中还未真正的使用RxJava2，不敢妄动笔墨。...所以这次还是给大家分享一个使用RxJava1解决问题的案例，希望对大家在使用RxJava的时候有一点点启发。...下面我们来看看使用RxJava如何清晰简洁的来实现这个复杂的业务： Observable observableForGetWeatherData; //首先创建一个从数据库获取天气数据的...我们在observableForGetWeatherData中使用distinct和takeUntil过滤筛选天气数据的时候网络请求会不会已经发出去了？这样做还有意义吗？欢迎大家留言讨论。...本文中的代码在MinimalistWeather中的WeatherDataRepository类中有同样的实现，文章中为了更完整的将整个实现过程呈现出来，对代码做了部分改动。

1.3K8 0

Android 中 RxJava 的使用

在事件处理过程中出异常时，onError() 会被触发，同时队列自动终止，不允许再有事件发出。...在一个正确运行的事件序列中, onCompleted() 和 onError() 有且只有一个，并且是事件序列中的最后一个。...但是不能就都用Flowable 因为Observable的性能较高 Single：和Observable，Flowable一样会发送数据，不同的是订阅后只能接受到一次普通Observable可以使用...首先假设这么一种需求：上面的{"11","22","33"}我们像最终获取到1,1,2,2,3,3 String[] strs = {"11","22","33"}; Observable .fromArray..., io.reactivex.subjects.ReplaySubject, io.reactivex.subjects.UnicastSubject 在RxJava2中依然存在，但现在他们不支持backpressure

2.2K3 0

Rxjs 响应式编程-第三章: 构建并发程序

然后，我将向您展示如何使用管道来构建程序，而不依赖于外部状态或副作用，将所有逻辑和状态封装在Observables本身中。...使用它的常见方案是缓存值或跟踪程序中更改的值。但是，正如您将在前面的Spaceship Reactive！中看到的那样，可以通过其他几种方式处理这些场景。...在一个Observable中，在我们订阅它之前，没有任何事情发生过，无论我们应用了多少查询和转换。当我们调用像map这样的变换时，我们其实只运行了一个函数，它将对数组的每个项目进行一次操作。...这是否意味着AsyncSubject像Promise一样？确实。 AsyncSubject表示异步操作的结果，您可以将其用作promise的替代。...我们也可以使用isVisible来过滤屏幕外的敌人，就像我们在return语句中所做的那样。我们需要更新paintEnemies，以便渲染敌人的镜头并更新他们的y坐标。

3.6K3 0

RxJS 入门到搬砖之 Subscription 和 Subject

在之前的 RxJS 中，Subscription 被称为 Disposable。...RxJS 中的 Subject 是一种特殊类型的 Observable，它允许将值多播到多个 Observer。...给定一个 Subject，可以订阅它，使用 Observer 开始正常接收值。...这是 Subject 如何使任何 Observable 执行共享给多个 Observer 的唯一方法。...多播的 Observable 在底层使用 Subject 来让多个 Observer 看到相同的 Observable 执行。

9021 0

RxJS Subject

我们可以使用日常生活中，期刊订阅的例子来形象地解释一下上面的概念。期刊订阅包含两个主要的角色：期刊出版方和订阅者，他们之间的关系如下：期刊出版方 —— 负责期刊的出版和发行工作。...在观察者模式中也有两个主要角色：Subject（主题）和 Observer （观察者），它们分别对应例子中的期刊出版方和订阅者。...但有些时候，我们会希望在第二次订阅的时候，不会从头开始接收 Observable 发出的值，而是从第一次订阅当前正在处理的值开始发送，我们把这种处理方式成为组播。上述的需求要如何实现呢？...Subject 之所以具有 Observable 中的所有方法，是因为 Subject 类继承了 Observable 类，在 Subject 类中有五个重要的方法： next —— 每当 Subject...Angular RxJS Subject 应用在 Angular 中，我们可以利用 RxJS Subject 来实现组件间通信，具体示例如下： message.service.ts import {

2K3 1

Architecture Components 生命周期

不过我们不能仅仅停留在使用的层面上，了解每个部分是如何工作的，探索官方的实现方式，这样技术才能进步，看源码的过程中我们可以带着几个问题去探索： Lifecycle是如何感知到Activity/Fragment...ViewModel的生命周期是如何控制。 LiveData中的数据是如何根据Lifecycle生命周期进行通知的？...MVP时代感知生命周期的做法众所周知，在使用MVP的时候，需要关联View的生命周期，在那个时候，生命周期的控制经历了几个阶段，从最开始官方Demo中的attach和detach，通过Activity...这又会分为两种，根据RxJava的版本不同，RxJava1和RxJava2的解除订阅的方式不一样。...MVVM中的生命周期的控制是如何实现的呢？

5675 0

Android消息总线的演进之路：用LiveDataBus替代RxBus、EventBus

这个主题对象在自身状态变化时，会通知所有订阅者对象，使它们能够自动更新自己的状态。 ? RxBus的出现 RxBus不是一个库，而是一个文件，实现只有短短30行代码。...作为比较，EventBus JAR包大小为57kb，RxBus依赖RxJava和RxAndroid，其中RxJava2包大小2.2MB，RxJava1包大小1.1MB，RxAndroid包大小9kb。...问题出现对于LiveDataBus的第一版实现，我们发现，在使用这个LiveDataBus的过程中，订阅者会收到订阅之前发布的消息。对于一个消息总线来说，这是不可接受的。...在LiveData的considerNotify方法中，红框中的逻辑是关键，如果ObserverWrapper的mLastVersion小于LiveData的mVersion，就会去回调mObserver...那么对于observeForever，如何解决这个问题呢？既然是在调用内回调的，那么我们可以写一个ObserverWrapper，把真正的回调给包装起来。

2.4K3 0

Rxjava2-小白入门(二)

那么这节课我们主要讲解Rxjava2的基本使用和操作符。其实网上的关于Rxjava2的优秀文章有很多对我来说都是受益匪浅。...不是讲Rxjava2吗？其实RxAndroid，这是一个扩展库，更好的兼容了Android特性，比如主线程，UI事件等。...首先我们先了解如何创建。...它和 Subscriber.onStart() 同样是在 subscribe() 调用后而且在事件发送前执行，但区别在于它可以指定线程 ---- 案例在了解了Rxjava2的原理，创建和使用下面我就该学习他的操作符了...当然实际应用中它可不是简单的这么使用的。

1.1K2 0

MVVM的数据持久化（一）——ROOM的集成

1.5K2 0

RxJava2 实战知识梳理(6) - 基于错误类型的重试请求

下面我们就来演示如何通过RxJava2来轻松实现上面的三点需求，通过这篇文章，我们将学习retryWhen操作符的具体用法，retryWhen和repeatWhen经常被大家用来比较，如果对repeatWhen...感兴趣的同学可以阅读上一篇文章 RxJava2 实战知识梳理(5) - 简单及进阶的轮询操作。...在Function函数中，必须对输入的 Observable进行处理，这里我们使用的是flatMap操作符接收上游的数据，对于flatMap的解释，大家可以参考 RxJava2 实战知识梳理...2.2 retryWhen 和 repeatWhen 对比在 RxJava2 实战知识梳理(5) - 简单及进阶的轮询操作中我们已经对repeatWhen进行了介绍，让我们再来看一下它的原理图...就像我们在上面例子中做的那样，我们通过flatMap操作符获取到异常的类型，然后根据异常的类型选择动态地决定延迟重试的时间，再用Timer操作符实现延迟重试；当然，对于一些异常，我们可以直接选择不重试，

1.4K1 0

深入RxJava2 源码解析(一)

其简化了异步多线程编程，在以前多线程编程的世界中，锁、可重入锁、同步队列器、信号量、并发同步器、同步计数器、并行框架等都是具有一定的使用门槛，稍有不慎或者使用不成熟或对其源码理解不深入都会造成相应的程序错误和程序性能的低下...观察者模型 24种设计模式的一种，观察者Observer和主题Subject之间建立组合关系：Subject类实例中包含观察者Observer的引用，增加引用的目的就是为了通知notify，重要点就是要在...基本使用使用RxJava2大致分为四个操作：建立数据发布者添加数据变换函数设置数据发布线程池机制，订阅线程池机制添加数据订阅者 // 创建flowable Flowable<Map<String...回归主题，当我们使用操作符和线程池机制的时候做法都是在数据发布者后面进行相应的函数操作： Disposable disposeable = scheduleObservable...以FlowableSubscribeOn为例进行分析，这个类经常会用到，因为其内部设置了线程池的机制所以在实际使用项目中会大量使用，那么是如何做到线程池方式的呢？进一步利用源码进行分析。

1.2K2 0

【响应式编程的思维艺术】（4）从打飞机游戏理解并发与流的融合

AsyncSubject AsyncSubject观察的序列完成后它才会发出最后一个值，并永远缓存这个值，之后订阅这个AsyncSubject的观察者都会立刻得到这个值。...笔者在自己的实现中又加入了右键切换飞船类型的功能，必须得说开发游戏的确比写业务逻辑要有意思。由于没有精确计算雪碧图的坐标，所以在碰撞检测时会有一些偏差。三....所以自动启动的方法也很简单，为那些不容易触发首次数据的流添加一个初始值就可以了，就像笔者在上述实现右键来更换飞船外观时所实现的那样，使用startWith运算符提供一个初始值后，在鼠标移动时combineLatest...限制scan操作符聚合结果的大小自己写代码时多处使用scan操作符对产生的数据进行聚合，如果聚合的形式是集合形式的，其所占空间就会随着时间推移越来越大，解决的办法就是在scan操作符接收的回调函数中利用数组的...参考代码及Demo说明 demo中的index.html是学习原文时拷贝的代码，mygame中的代码是笔者写的，有需要的读者自行使用即可。

8714 0

Android程序员该如何去手写事件通信方案LiveDataBus

二、LiveData使用在了解LiveData定义和优点后，那它到底怎么应用呢？...四、LiveData主要涉及到的时序有三个：在Fragment/Activity中通过LiveData.observer()添加观察者（observer()方法中的第二个参数）。...如何使用Android的LiveData 使用Android的LiveData，需要在gradle添加引用： compile "android.arch.lifecycle:runtime:1.0.0...在LiveData中，onActive方法回调表明当前Activity处于激活状态，也就是Activity处于生命周期的活动状态中（onStart，onResume），可以简单认为当前的Activity...作为比较，EventBus JAR包大小为57kb，RxBus依赖RxJava和RxAndroid，其中RxJava2包大小2.2MB，RxJava1包大小1.1MB，RxAndroid包大小9kb。

1.4K1 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云