当我们在rxjava中使用观察者时，到底会发生什么？
当我们在RxJava中使用观察者时，会发生以下过程：
- 创建观察者（Observer）对象：我们需要创建一个实现Observer接口的观察者对象，该对象定义了观察者在接收到数据时的行为。
- 创建被观察者（Observable）对象：我们需要创建一个实现Observable接口的被观察者对象，该对象负责产生数据并通知观察者。
- 订阅观察者：通过调用Observable对象的subscribe()方法，将观察者订阅到被观察者上，建立观察者和被观察者之间的关联。
- 发送数据：被观察者开始发送数据，可以通过调用Observable对象的onNext()方法来发送数据给观察者。
- 观察者接收数据：观察者通过实现Observer接口的onNext()方法来接收被观察者发送的数据，并对数据进行处理。
- 完成通知：当被观察者发送完所有数据后，会调用Observer接口的onComplete()方法来通知观察者数据发送完成。
- 错误处理：如果在发送数据的过程中出现错误，被观察者会调用Observer接口的onError()方法来通知观察者，并传递错误信息。
需要注意的是，RxJava中的观察者模式是基于异步编程的，所以观察者和被观察者是在不同的线程中执行的。观察者模式可以帮助我们实现响应式编程，将数据流和操作流进行解耦，提高代码的可读性和可维护性。
在腾讯云的产品中，与RxJava相关的产品包括云函数SCF（Serverless Cloud Function）和消息队列CMQ（Cloud Message Queue）。云函数SCF可以作为被观察者，通过触发器来触发函数执行，并将执行结果发送给观察者。消息队列CMQ可以作为观察者，接收和处理被观察者发送的消息。这些产品可以帮助开发者构建基于RxJava的异步编程应用。
相关·内容
1回答
我已经开始学习RxJava和RxAndroid了。我想用RxJava替换我的观察者模式。观察者模式类似于具有注册和注销方法的安卓LocationManager类。"observable“类(不是指rx.Observable)在它自己的线程(HandlerThread)中工作，并拥有侦听器及其处理程序对象的映射，每个侦听器在其线程中被调用(通过处理程序)。我想这很明显。因此，问题是如何使用RxJava实现它？这有意义吗？我读过关于PublishSubject和Subscriber的文章，但我不知道如何在它的线程中运行我的Observable。我不想使用"subscribeOn“方
浏览 3提问于2016-11-02得票数 0
我有一个绑定服务，负责下载文件，因此它知道下载状态/进度。UI (片段或活动)必须显示/更新服务的下载进度。
实际上，我认为常用的方法是使用活动中的BroadcastReciever或CallBack。但是，我听说过使用RxJava (ReactiveX编程)和中介类(以及Dagger将其注入服务和活动中)，如下所述。
所以我的问题是如何处理这些东西的RxJava？有密码样本吗？还有比使用意图更有效的方法吗？
资源：参见第一个应答更新
浏览 0提问于2015-11-20得票数 18
我们在web上使用ReadSpeaker组件。我们有一个开始阅读的按钮，我们调用Readspeaker的一个名为readpage()的函数)当我们点击这个按钮时，问题就开始了，整个网页都被破坏了，就好像网页在没有CSS的情况下变成了pdf文件，按钮消失了。
知道发生了什么吗？对不起，我不能很好地解释它，我不知道到底会发生什么。
浏览 15提问于2017-08-28得票数 1
我是RxJava2的新手，我使用了defer、concat和create等其他方法。我正在努力寻找一种实现上述内容的方法。
具体的需要是，我有一个片段，显示和隐藏。这个片段有subscribers到EventBus事件。这些事件是由我一直在后台运行的服务触发的。
当碎片被隐藏时我不想失去他的排放。相反，我想以某种方式cache在隐藏时发出的排放物，然后在显示片段时释放它们。
是否有使用RxJava2 API的内置解决方案？
浏览 0提问于2017-01-31得票数 0
回答已采纳
1回答
我对RxJava全球处理程序和Android有疑问。在Android Vitals中我可以看到
io.reactivex.exceptions.UndeliverableException
造成: com.google.common.util.concurrent.AbstractFuture.get (AbstractFuture.java:527) at com.google.common.util.concurrent.FluentFuture$TrustedFuture.get (FluentFuture.java:82)
但是我已经不知道问题出在哪里了，所以我考虑添加RxJa
浏览 3提问于2019-08-20得票数 0
2回答
我们能否检测到一个类成员值是否正在使用RxJava进行更改？？假设在一个类中有一个变量var，那么当var的值使用RxJava发生变化时，我们可以得到通知吗？
浏览 6提问于2016-07-05得票数 9
回答已采纳
当我使用Observable.subscribe()时，通常返回Disposable。
但是Observable.subscribe(观察者)返回空。
所以我不能处置给Observable.subscribe(观察者)。
根据introtorx.com的说法，Observable.subscribe(Obeserver)返回Disposable。
为什么rx和rxjava不同？
++++++++++++++
我在Android Studio中使用compile 'io.reactivex.rxjava2:rxandroid:2.0.1'。
github.com/Reactive
浏览 5提问于2017-06-16得票数 6
我正在考虑如何使我的iPhone应用程序尽可能地“防弹”。
现在，我正在考虑应用程序将如何响应用户在应用程序处理的关键时刻按下home按钮。
到底会发生什么？还有更多的指令在应用程序的线程中执行吗？
当applicationWillTerminate被调用时，我读到应用程序“在os杀死进程之前有几秒钟的时间”--同样，到底会发生什么呢？
浏览 1提问于2009-01-20得票数 8
回答已采纳
那么，当有人在PHP中说“new”时到底会发生什么呢？
我相信在C/Java中，当调用new时，会为对象所需的每个实例变量分配内存。(如果我错了，请纠正我)
PHP也是这样吗？
浏览 0提问于2010-07-29得票数 5
回答已采纳
在这里问一个非常基本的RxJava问题，因为我在其他地方找不到它。
我在RxJava 2里看到了这个-
Observable<String> database = Observable.just("1", "2", "3");
效果很好。没问题。
但当我试图传递这样的数组时-
arr = new String[]{"1", "2", "3"};
Observable<String> database = Observable.just(arr);
它会引发不兼容类型的错误。
浏览 0提问于2018-05-05得票数 1
回答已采纳
我不清楚如何在RXJava中实现任务取消。
我对移植使用番石榴的ListenableFuture构建的现有API很感兴趣。我的用例如下：
我有一个单一的操作，由Futures.transform()加入的一系列期货组成
多个订阅者观察操作的最终未来。
每个观察者都可以取消最终的未来，所有的观察员都可以见证取消事件。
最终未来的取消将导致其依赖项的取消，例如，在序列中，3的3取消被传播到2，等等。
RxJava wiki中几乎没有这方面的信息；我可以找到的唯一可以取消的引用都提到了Subscription相当于.NET的Disposable，但据我所见，订阅只提供了从序列
浏览 4提问于2014-08-16得票数 14
回答已采纳
如何在后台而不是活动/片段中使用RxJava2中的单个观测器。
我知道如果单使用在活动/片段，那么它可以添加到复合处置器，并处置它的活动/片段的onDestroy方法。
但是，当从其他地方调用它时，如何处理它呢？
另外，如果从活动/片段调用了单个代码，并且我们希望在调用onDestroy之前将其释放，那么其他的处理方法是什么呢？
浏览 0提问于2018-10-29得票数 3
当一个集合达到0个元素时，RxJava惯用的方法是什么？
我看过这个答案：，我可以看到如何用定制的ObservableHashSet包装一个HashSet，然后在remove()方法中，如果大小为0，则调用onCompleted。
这是正确的方式吗？有没有更简单的/内置的方法？
浏览 0提问于2016-09-20得票数 2
2回答
例如，当NullPointerException在调用RxJava映射操作符后发生时，应用程序不会崩溃。我希望应用程序崩溃时，当这种情况发生，以便它可以提交报告，以崩溃等。
我尝试在try/catch块中使用Exceptions.propagate()，但这没有起作用。
我找到的唯一解决方案是在我的错误处理程序中抛出一个RuntimeException。
override fun getCategories(): Single<List<Category>> {
return ApiManager
.getCate
浏览 4提问于2019-10-04得票数 0
回答已采纳
我一直在尝试理解加载php作为apache模块与其他模块的确切含义/目的。
当php作为apache模块安装时，到底会发生什么？例如，读取php-ini文件是在每次收到php请求时发生还是在单独加载php模块时发生？
浏览 0提问于2010-10-17得票数 54
回答已采纳
我正在编写一个可观察到的，用来处理与安卓服务的连接的，它是以RxAndroidBle的.establishConnection()为模型的。
我知道.establishConnection()从不调用.onComplete()；在它发出连接之后，它要么由订阅者释放，要么以错误结束(通常是当连接丢失时)。但是，在释放连接时调用.onComplete()似乎是合理的。在这方面，我还没有找到官方的RxJava政策；似乎有些可观察到的人会这么做，而另一些人则不这样做。对于一个可以观察到的人来说，什么是正确的行为，它会发射出一个单一的物品，然后被处理掉？
浏览 0提问于2018-11-04得票数 0
回答已采纳
1回答
我正在尝试在SSAS中学习聚合，
我相信当我们创建一个多维数据集时，它会生成维度和事实，它已经生成了所有可能的组合，那么，当我们在SSAS中创建聚合时，到底会发生什么呢？
请帮帮忙
浏览 0提问于2014-08-09得票数 0
6回答
我有一个代码，其中包含一个递归函数。我已经在递归上浪费了很多时间，但我仍然不能真正得到它：
#include<stdio.h>
void count(int);
int main()
{
int x=10,z;
count(x);
}
void count(int m)
{
if(m>0)
count(m-1);
printf("%d",m);
}
当第一次在参数为10的情况下调用count时，它满足条件，然后开始递归部分。当函数调用自身时，到底会发生什么？我还是不明白。请参考堆栈进行说明。
浏览 8提问于2012-09-04得票数 3
当用户按下“主页”按钮时，应用程序到底会发生什么？iOS是否对当前应用程序的状态进行快照？
如果我是对的，如何“溜进”另一张快照？我需要它显示主iOS屏幕后，用户按下主按钮两次。
浏览 4提问于2014-03-15得票数 0
回答已采纳
1回答
我经常看到使用rxJava以反应式的方式编写API。我已经学习了rxJava的基础知识，并且曾经认为我知道它是如何工作的。但是当我在API的上下文中再次思考它时，我开始不理解它。为什么在没有观察者订阅可观察对象的情况下，API可以工作并返回响应？ 在rxJava中，它通常使用observable和observer来解释，并且有一个订阅操作，例如 Observable<String> source = source.just("a", "b");
source.subscribe(s -> System.out.println(s)); 但是在
浏览 16提问于2020-08-14得票数 0
回答已采纳
我在我的安卓项目中使用了RxJava2。
我使用以下代码来创建Observable
public Observable<AlbumDetails> loadAlbumFromAlbumId(final String albumId) {
return Observable.fromCallable(new Callable<AlbumDetails>() {
@Override
public AlbumDetails call() throws Exception {
AlbumDetails album
浏览 3提问于2017-05-04得票数 15
这是我在Kotlin的测试代码：
fun main() {
rxjava()
}
fun rxjava() {
val queuSubject = PublishSubject.create<String>()
queuSubject
.map { t ->
val a = t.toLong()
Thread.sleep(6000 / a)
println("map $a called ${Thread.currentThread().name} "
浏览 2提问于2021-07-02得票数 1
回答已采纳
1回答
如果您传递给.subscribe()方法一个Observer，那么它会返回void，但是当传递其他任何东西时，会返回Disposable。我意识到这与反应流规范有关，但还是与…有关。
Observer提供了.onSubscribe( Disposable )方法，但是当我阅读ReactiveX Observable契约时，这个方法可能会在Observer订阅时被调用，也可能不会被调用。对RxJava2来说是这样吗？它似乎只需要由Flowable调用，它使用它通知Subscriber它已经准备好接受请求。
我读到过.subscribeWith( Observer )以某种方式解决了这个问题，但我
浏览 0提问于2018-03-24得票数 1
回答已采纳
我有一个非常简单的RXJava发射器。它实际上是一个publishSubject，但它的任务是将整数转换为字符串，并在订阅后更新UI元素。代码如下所示：
PublishSubject integerToStringEmitter = PublishSubject.create();
Subscription mysingle= Single.just(4).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
浏览 5提问于2016-03-19得票数 1
回答已采纳
我在Oracle的网站上发现了类似的代码。因为空间的原因，我剥去了一些与布局无关的东西。
private JTextField textField;
public class TextDemo extends JPanel implements ActionListener
{
public TextDemo()
{
textField = new JTextField(5);
//This causes a leaking this in constructor warning...
textField.addActionLi
浏览 1提问于2013-04-30得票数 2
回答已采纳
我想知道为什么subscribeWith方法返回订阅者，但不是严格可处理的，或者可能是订阅。
我认为subscribeWith方法是为使用返回订阅的RxJava 1.x的subscribe方法而设计的。因此，在2.0中，我认为subscribeWith方法的主要用法将是与实现Disposable的订阅服务器一起使用。
但是，由于subscribeWith方法可以返回订阅服务器，所以可以使用类似主题的用法(如下面的代码)。
Subscriber<Long> subscriber = Flowable.interval(100, TimeUnit.MILLISECONDS)
.
浏览 14提问于2016-10-12得票数 2
回答已采纳
在Kotlin Coroutines库中是否有来自RxJava的等价物PublishSubject？
通道不能替代PublishSubject，因为它们不向多个收集器发布值(每个值只能由一个收集器收集)。即使是支持多个收集器的MutableSharedFlow，仍然不允许在不等待收集器处理完以前的值的情况下发送值。如何创建具有类似于PublishSubject的功能的流
浏览 11提问于2021-05-24得票数 0
2回答
我用的是Rxjava和Retrofit。我知道如何使用它，但我仍然不清楚“Rxjava对Retrofit到底做了什么”。
我们对REST调用使用任何转换器(如Gson)和Okhttp库进行改造，一旦得到响应，它就具有可观察的类型(如果使用Rxjava，否则它将是调用类型)。现在的问题是，如果我们已经得到响应，那么Rxjava究竟是如何处理这个响应的呢？
到目前为止，通过查看代码，Rxjava首先采用了可观测响应，然后使用操作符对进行了一些操作，已经得到了响应，然后它只将最后的响应发送给观察者，从那里可以将数据膨胀成视图。
首先，如果我对Rxjava的理解是错误的，请告诉我。
对进
浏览 0提问于2017-09-11得票数 0
回答已采纳
我在.net中有一个类库项目，名为"A“，在构建时将创建一个名为"A.dll”的动态链接库。我有另一个项目名为"B“，这个项目包含动态链接库"A.dll”的引用。当我在B中添加A的引用时，到底会发生什么？有人能告诉我在编译时和运行时都发生了什么吗？
浏览 0提问于2010-11-09得票数 2
回答已采纳
我在玩rxJava/rxAndroid，有些非常基本的东西不像我期望的那样表现。我有一个可观察的和两个订户：
Observable<Integer> dataStream = Observable.just(1, 2, 3).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
Log.d(TAG, "subscribing sub1...");
dataStream.subscribe(v -> System.out.println("Subscriber #
浏览 2提问于2017-01-28得票数 21
回答已采纳
当int类型转换为long类型时，到底会发生什么？
例如：
a = sys.maxint-1
a = a+2
a = a + 2的语句中发生了什么
Python解释器如何处理溢出？
浏览 0提问于2013-04-03得票数 3
1回答
我将以下语句添加到我的模块级build.gradle文件中，这样我就可以在我的颤振插件中使用Rx了。
implementation "io.reactivex.rxjava2:rxkotlin:2.x.y"
implementation 'io.reactivex.rxjava3:rxjava:2.2.7'
implementation 'io.reactivex.rxjava3:rxandroid:2.1.1'
当我键入要声明时，IDE似乎不识别库(io.reactivex)
val observable : Observable
这是否意味
浏览 1提问于2021-11-19得票数 0
1回答
在使用Django时，我注意到当我发送电子邮件时会出现延迟，为了克服这个问题，我不得不使用芹菜工具。所以我想知道引擎盖下面到底发生了什么。为什么Django/Python需要一个异步工具来完成这个任务。我已经了解了MultiThreading，MultiProcessing在Python中的用法，但是如果有人能给我一个简短的概念，当Django试图不使用芹菜发送电子邮件时，到底会发生什么。
浏览 1提问于2019-07-18得票数 1
回答已采纳
1回答
我是rxjava的新手，刚刚开始学习它，并将我们的android项目转换为rx。因此，我编写了可观察对象，并使用平面地图将它们链接起来，以调用apis并返回一个可观察对象。现在，在主要活动中，我订阅它们，并根据需要将我的UI代码添加到onNext、onSubscribe、onComplete和onError。但是我有多个api，我已经为每个api创建了一个observable，但我想在订阅它们的观察者上有一个包装器。它主要是执行一段代码，比如登录onNext/onError调用，在onSubscribe上显示进度状态，在onComplete/onError上关闭它，等等。
除了每次都添加它，或
浏览 0提问于2017-12-11得票数 1
我从firebase获得以下消息: runTransactionBlock:在启用持久性时检测到的使用情况。请注意，在应用程序重新启动期间，事务将不会持久化。
那么，在应用程序重新启动之后到底会发生什么呢？本地数据库中的更新是否由于来自主数据库的同步事件而被覆盖？还有别的吗？
浏览 3提问于2016-03-08得票数 3
回答已采纳
1回答
如何用可观测替代可处理
、、、、
我是RxJava的新手。
我学到的第一件事之一是，观察者模式包括两个组件(除其他外)：可观测的、和观察者。
在下面的代码中，什么是可观察的，什么是观察者？
class JsonRepository{
private val client by lazy {
Retrofit.Builder()
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.baseUrl(
浏览 0提问于2019-05-14得票数 0
当使用解构赋值语法时，如果LHS (左边)上的括号被去掉了，会发生什么？例如： {
let a,b = [1,2];
console.log(a, b);
}
{
let [a,b] = [1,2];
console.log(a, b);
} 如果不包括括号，是否等同于执行以下操作： let a=undefined, b=[1,2]; 或者，当括号被去掉时，到底会发生什么？
浏览 12提问于2021-10-09得票数 0
回答已采纳
2回答
在安卓系统中，当我按下主页按钮时，到底会发生什么？因为当我在按下主页按钮后再次打开它时，它有一系列的bug。我需要知道它才能追踪到引起这个bug的地方。
更新:当按下主页按钮时，应用程序转到后台，onPause()被调用并保存UI的状态，但它不保存应用程序的状态，如变量、自定义视图。你必须手动保存它们，就像Oren解释的那样。
浏览 0提问于2013-02-05得票数 2
回答已采纳
4回答
在Fibonacci序列中，我见过两次递归调用同一方法的传统实现：
public void fibonacci(int i)
{
fibonacci(1) + fibonacci(2);
}
现在这种方法并不是我所看到的完全相同的副本，也不是解决问题的正确方法，但我已经看到这两种方法像上面那样加在一起。所以该方法不是递归调用的，而是递归调用两次的。在C#中编写这样的代码时到底会发生什么？这两个方法是在不同的线程上运行的吗？引擎盖下发生了什么？
浏览 7提问于2008-12-26得票数 2
回答已采纳
当查询被触发时，客户端如何与impalad deamon联系？当客户端触发一个必须由黑斑羚执行的查询时，后台到底会发生什么？
浏览 1提问于2013-07-01得票数 1
1回答
在eclipse中终止程序时，到底发生了什么事件？这意味着，每当我们直接关闭程序，无论是在eclipse控制台中按下红色按钮还是关闭，到底会执行什么事件？如果你对此有所了解，请与我分享你的知识。
浏览 2提问于2014-04-05得票数 1
回答已采纳
我有一个使用RxJava的方法，它调用将json对象反序列化为一个java对象(POJO)。readValue方法抛出必须处理或抛出给我方法调用方的IOException。我不应该在这里处理它，而应该让我的来电者来处理。我如何在RxJava中做到这一点？通常，它只需要将throws IOException添加到我的方法签名中。
这是我的代码：
public Observable<T> findByIdAsync(String id) throws IOException {
return datasource
.getBucket()
浏览 2提问于2017-02-04得票数 1
回答已采纳
1回答
如果我为类Foo (在C++中)编写了一个操作符==，那么到底会发生什么？它会将每个数据成员相互比较吗？
class Foo
{
private:
int bar;
public:
bool operator==(const Foo other&)
{
return *this == other; //what?
//is this the same as bar == bar?
}
}
浏览 15提问于2009-07-28得票数 2
回答已采纳
我很好奇，如果在垃圾收集过程中终结器方法中发生了异常，那么.NET内部到底会发生什么。堆和陆的逻辑不同吗？有人能提供详细的描述吗？
浏览 2提问于2013-10-19得票数 5
回答已采纳
2回答
我刚开始使用rxjava，然后就卡住了。也许我没有以正确的方式使用rxjava，但我需要在创建Observable之后向它添加项。所以我知道你只需要调用Observable.just("Some", "Items")，订阅者就会收到它们，但是如果我有一个异步任务，并且我需要在稍后任务完成时添加更多的项目，那该怎么办？我找不到像Observable.addItems("Some", "More", "Items")这样的东西
浏览 0提问于2015-03-07得票数 28
回答已采纳
我有一个使用RxJava编写的spring boot微服务。我使用了spring安全机制，并使用JWT风格的令牌来保护它。在我使用RxJava io调度程序添加线程池之前，一切都运行得很好。我注意到，当线程池与spring安全一起使用时，会出现有线行为。当我保存数据时，会同时保存一个userId。当我作为userOne登录后创建第一个对象时，它是正确创建的。同样的道理也适用于userTwo。然后假设我以userThree身份登录并创建了一个新数据，该数据是针对错误的userOne ID保存的！只有当我在从池中获得的单独线程中执行操作时，这种行为才会出现。
我的安全配置文件如下所示：
publi
浏览 4提问于2018-03-30得票数 1
各位，我在互联网上读过一些关于RxJava的文章，目的是为了更好地理解它是什么，但我仍然觉得很难理解.COuld，任何人都给我建议：
RXJava是什么？
2-我们为什么要使用它？
浏览 2提问于2019-04-09得票数 0
回答已采纳
1回答
JSON
[
{
"countryName":"..."
},
{
"countryName":"..."
},
{
"countryName":"..."
} //etc... to 195 countries
]
接口
public interface RetrofitInterface {
@GET("GetCountries.php")
Single<List<Country
浏览 10提问于2021-12-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
