2回答
创造一个主题
、、、
我在RxJS中见过这种情况，但在RxJava中还没有找到类似的。有人知道如何在java中设置这样的东西吗？
观察员(观察员)：观察员用来向主题发送信息。
可观察的(可观察的)：可观察的用于订阅从
浏览 2提问于2015-01-20得票数 2
回答已采纳
我在写单元测试可完成的功能。在RxJava 2中，blockingGet()作为assertTrue(t instanceof MyException);
然而，在中，我再也看不到blockingGet()了。如何在RxJava 3中实现上述测试？
浏览 8提问于2022-05-26得票数 0
回答已采纳
我想观察一下我的BehaviourSubject。在RxJava 1中，我调用了，它现在已经消失了。
我找到了，但它返回了可连接的，我不想这样做。如何将行为主体转化为RxJava 2中的可观察对象？
浏览 4提问于2017-03-21得票数 9
1回答
我有一些方法： repository.get(arg1, arg2, arg3) 方法返回Single<List<SomeObject>> 我需要用特定的参数测试这个名为onSubscribe()的函数repository.get(arg1, arg2, arg3) .assertSubscribed() 这个方法忽略了我放在repository.get()方法中的参数如何使用某些<
浏览 6提问于2020-10-02得票数 0
所以，我最近开始了协同实验，我从Rxjava2切换到协同，我还没有掌握它，但我仍然遇到了一个条件，我需要观察我的数据库的变化，并更新UI与之相对应。RxJava曾经为我提供可流动的、可完成的等等，使用它我可以观察Db中的变化。* FROM somedata_table")
abstract fun getData(): Flowable<List<So
浏览 2提问于2019-01-31得票数 21
回答已采纳
是否有任何方法来决定是否应该由返回rxjava类型的方法引发异常，还是应该通过onError传播异常？如果我有一个方法，如果参数为null，应该抛出NPE，该异常是由该方法本身引发，还是通过可观察/可流动的返回抛出？
浏览 6提问于2021-09-22得票数 2
回答已采纳
如何将未来返回的空白转换为可流动或可观察的RxJava？
我使用的是RxJava和AndroidX WorkManager，后者提供了返回Future<void>的API。据我所知，RxJava不处理空值，因此将立即执行NullPointerException。动机：--我想把这个未来变成一个Rx可观察/可流动的，这样我就可以在这个未来完成之后进行处理。我需要
浏览 3提问于2020-12-18得票数 3
回答已采纳
我有一个应用程序，在该应用程序中，我开始将事件流表示为可观察的RxJava。事件的需求和结构在开始时很简单，RxJava附带的操作符非常适合于所需的简单转换。我的一个朋友(他也在做这个项目)多次提到RxJava应该被使用得简单得多。他说，他见过的任何基于RxJava的项目都使用简单的操作符，而无需在彼此之间嵌套自定义变压器。
测试</
浏览 1提问于2017-12-14得票数 3
1回答
我想在RXJava中将以下同步代码建模为异步代码。List<Action> handle() {} executeActionsAsync(actions) { action.forEach(functionexecuteAsync(actions);}
我想在RXJava2中做同样的模型。任何帮助都
浏览 0提问于2018-09-19得票数 8
1回答
在我的应用程序中，我使用存储库和RxJava访问业务对象。从我的Presenter层，我可以请求存储库为我获取ObjectA或ObjectB，然后存储库将分别返回一个可观察对象或可观察对象。我想知道使用RxJava获取这两个对象的选项是什么，它还允许对我的Presenter层进行单元测试。
我最初实现的方法是使用flatMap()运算符。一个问题是，尽管我的Repository类<
浏览 1提问于2016-12-03得票数 1
1回答
使用RxSwift进行长轮询
、、、、
我想用RxSwift发出一个简单的长轮询请求，它可能类似于下面的RxJava代码： .repeatWhen(obs -> observable.delaytakeUntil(searchResponse -> searchResponse.isCompleted)在RxSwift中，有一个运算符，它接受ObservableConvertibleType作为参数</em
浏览 111提问于2016-08-30得票数 1
回答已采纳
1回答
我正在努力学习Rxjava，并且仍然处于一个非常基本的水平。我正在寻找一些关于以下问题的指导。我有这两个可以观察到的， return ConnectableObservable.interval如您所见，在getPlayheadPositionInMilliseconds中，订阅者将在每1000 As之后获得新值，现
浏览 1提问于2019-07-31得票数 1
回答已采纳
如何在rxjava链的doOnScubscribe和doFinally上创建特定副作用的单元测试？showLoading = false)如何在上面的场景中测试showLoading在订阅时被设置为true，当可观察到的被释放时被
浏览 0提问于2018-02-26得票数 1
回答已采纳
2回答
我希望将同步方法从parse.com (主要是ParseObject.save() )包装到RxJava包装器中。ParseException e) { } });这给了我一个错误:不可观察的应用于无效基本上，是否有任何方法将此调用包装在RxJava中，并在保存成功时得到通知？
浏览 1提问于2016-10-22得票数 0
回答已采纳
1回答
Android Studio 4在我的活动中： .subscribeOn(Schedulers.ioToast.makeText(this, throwable.message, Toast.LENGTH_LONG).show()在我的ViewModel但是这种方法的问题在于，活动了解线程之间<em
浏览 0提问于2020-07-16得票数 0
1回答
如何用可观测替代可处理
、、、、
我是RxJava的新手。在下面的代码中，什么是可观察的，什么是观察者？JsonRepository{
Retrofit.Builder()
.addCallAdapterFactory(RxJava2CallAdapterFactor
浏览 0提问于2019-05-14得票数 0
可观察的界面和可流动的界面似乎是相同的。为什么在RxJava 2.0中引入了Flowable？什么时候我应该更喜欢使用Flowable而不是Observable？
浏览 0提问于2016-12-03得票数 33
回答已采纳
2回答
在RxJava2中引入了新的Flowable。如何在android中使用它。在RxJava1中没有可流动的。
浏览 0提问于2016-08-29得票数 10
回答已采纳
谁能用清晰的例子解释一下RxJava中可观察、可完成和单一之间的区别？
在哪种情况下，我们使用一个而不是其他的？
浏览 2提问于2017-03-13得票数 132
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
