RxJava --两个观察量
RxJava是一个在Java虚拟机上实现的响应式编程库。它基于观察者模式，通过使用可观察序列（Observables）和观察者（Observers）来实现异步、基于事件的程序。RxJava提供了丰富的操作符，可以方便地处理数据流，实现数据的转换、过滤、组合等操作。
RxJava的优势包括：
- 异步和并发处理：RxJava可以轻松地处理异步操作和并发任务，通过使用观察者模式和操作符，可以实现简洁、可读性高的异步代码。
- 响应式编程：RxJava支持响应式编程范式，可以将复杂的业务逻辑分解为简单的数据流操作，提高代码的可维护性和可测试性。
- 容错和错误处理：RxJava提供了丰富的错误处理机制，可以方便地处理异常情况，并提供了重试、重放等操作符来增加程序的容错性。
- 背压支持：RxJava通过Flowable类型提供了背压支持，可以解决生产者和消费者之间的速度不匹配问题，避免数据丢失和内存溢出等问题。
RxJava的应用场景包括：
- 异步任务处理：RxJava可以用于处理异步任务，例如网络请求、文件读写等操作，通过使用观察者模式和操作符，可以实现简洁、可读性高的异步代码。
- 数据流处理：RxJava可以用于处理数据流，例如数据的转换、过滤、组合等操作，通过使用操作符，可以方便地实现复杂的数据处理逻辑。
- 响应式UI编程：RxJava可以用于实现响应式UI编程，例如根据用户输入实时更新界面、处理用户事件等，通过使用观察者模式和操作符，可以实现响应式的用户界面。
腾讯云提供了与RxJava相关的产品和服务，例如：
- 云函数（Serverless Cloud Function）：腾讯云云函数是一种无服务器计算服务，可以用于处理异步任务和事件驱动的编程模型，可以与RxJava结合使用，实现灵活的异步编程。
- 弹性缓存Redis（TencentDB for Redis）：腾讯云弹性缓存Redis是一种高性能、可扩展的内存数据库服务，可以与RxJava结合使用，实现高效的数据流处理和缓存操作。
更多关于腾讯云产品和服务的信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我是RxJava的新手，遇到了下一个问题:我有两个流：
Stream 1: -●-●-●-●-●-●-●-●-●-●-●->
Stream 2: -▲-▲-▲-▲-▲-▲-▲-▲-▲-▲-▲->
我需要下一步从这两个流中组合出第三个流：
Stream 3: -●-●-▲-●-●-▲-●-●-▲-●-●-▲->
这意味着我们有来自S1的两个元素和来自S2的元素，来自S1的两个元素和来自S2的元素……
如何使用RxJava来完成此任务？
浏览 0提问于2015-10-21得票数 1
我想运行两个异步任务，一个接着另一个(按顺序)。我读过一些关于ZIP或扁平的东西，但我不是很理解它…
我的目的是从本地SQLite加载数据，当它完成时，它调用对服务器的查询(远程)。
有人能给我提个建议吗，一种实现这一目标的方法？
这是我正在使用的RxJava可观察框架(单任务)：
// RxJava Observable
Observable.OnSubscribe<Object> onSubscribe = subscriber -> {
try {
// Do the query or long task...
浏览 4提问于2016-01-12得票数 15
回答已采纳
1回答
如何用可观测替代可处理
、、、、
我是RxJava的新手。
我学到的第一件事之一是，观察者模式包括两个组件(除其他外)：可观测的、和观察者。
在下面的代码中，什么是可观察的，什么是观察者？
class JsonRepository{
private val client by lazy {
Retrofit.Builder()
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.baseUrl(
浏览 0提问于2019-05-14得票数 0
这里有一个使用反应性编程的例子(例如使用RxJava )。
有一个具有某些属性(名称、姓氏)的用户对象--可观察到的
一个活动包含两个片段，它们都显示当前用户名--订阅者。
用户更改(名称更改)
是正确的假设:如果观察到的数据源发生变化(如果两个片段都订阅同一个用户对象)，则显示的名称将自动更改？？
从我现在看到的情况来看，关于rxjava和android的所有例子都集中在异步调用和处理由订阅触发/调用的返回数据流上。如果被观察到的源发生变化，应该/将发生什么？订户是否应该被触发？
从这里拍摄：
例如，在命令式编程设置中，a:=b+c意味着在计算表达式的瞬间，a被分配给b
浏览 4提问于2017-01-28得票数 3
回答已采纳
我在玩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
回答已采纳
我的build.gradle
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile "io.reactivex.rxjava2:rxjava:2.1.0"
在使用确切的库时，External Libraries在我的一个项目中显示了rxandroid-1.2.0 & rxandroid-2.0.1，而在另一个项目中只显示了后者。
1.2.0使用与rx.Observable兼容的rx.android.schedulers.Scheduler;，如下所示：
someRxObservable
.sub
浏览 12提问于2017-06-22得票数 4
回答已采纳
8回答
TL；博士如何将Task.whenAll(List<Task>)转换为RxJava
我的现有代码使用Bolts构建异步任务列表，并在执行其他步骤之前等待所有这些任务完成。本质上，它构建一个List<Task>并返回一个Task，当列表中的所有任务按照完成时标记为已完成。
我希望用Bolts代替RxJava，并且我假设这种方法可以建立异步任务列表(事先不知道大小)，并将它们全部封装到单个Observable中，但我不知道如何实现。
我试过看merge，zip，concat等.但是，如果我正确地理解了文档，就无法处理我正在构建的List<Observable>，
浏览 21提问于2016-02-12得票数 102
回答已采纳
2回答
RxJava 2
我试图在rxJava中进行非常简单的重试，这将重试3次，然后导致原始错误。我现在拥有的是：
public void retry3() {
Observable<Object> retry = Observable
.error(new IllegalStateException())
.retryWhen(errors -> errors
.zipWith(Observable.range(1, 3), (n, i) -> {
System.out
浏览 3提问于2017-05-09得票数 0
回答已采纳
我想观察一下我的BehaviourSubject。在RxJava 1中，我调用了，它现在已经消失了。
我找到了，但它返回了可连接的，我不想这样做。
如何将行为主体转化为RxJava 2中的可观察对象？
浏览 4提问于2017-03-21得票数 9
各位，我在互联网上读过一些关于RxJava的文章，目的是为了更好地理解它是什么，但我仍然觉得很难理解.COuld，任何人都给我建议：
RXJava是什么？
2-我们为什么要使用它？
浏览 2提问于2019-04-09得票数 0
回答已采纳
1回答
我已经开始学习RxJava和RxAndroid了。我想用RxJava替换我的观察者模式。观察者模式类似于具有注册和注销方法的安卓LocationManager类。"observable“类(不是指rx.Observable)在它自己的线程(HandlerThread)中工作，并拥有侦听器及其处理程序对象的映射，每个侦听器在其线程中被调用(通过处理程序)。我想这很明显。因此，问题是如何使用RxJava实现它？这有意义吗？我读过关于PublishSubject和Subscriber的文章，但我不知道如何在它的线程中运行我的Observable。我不想使用"subscribeOn“方
浏览 3提问于2016-11-02得票数 0
2回答
TL；DR -在默认情况下，在观察可观测事件时只使用一个线程吗？
在我看来，RxJava2通常是顺序的，除非通过并行()之类的东西来表示。即使对doOnNext()进行了观察/订阅，我仍然看到，对于()，从来没有两个线程同时运行：
AtomicInteger counter = new AtomicInteger();
PublishSubject<Integer> testSubject = PublishSubject.create();
testSubject
.observeOn(Schedulers.io())
.doOnNext(val -> {
if(c
浏览 1提问于2019-07-23得票数 2
回答已采纳
2回答
让我们假设我对Android有以下情况：
来自网络的组请求列表
显示每个组的一些UI元素
每个组的请求项
显示每个项目的UI元素集
我想使用RxJava来完成这个任务：
webService.requestGroups()
.flatMap(group -> {
view.showGroup(group);
return webService.requestItems(group);
})
.toList()
.subscribeOn(Scheduler
浏览 4提问于2017-09-06得票数 14
我在一个项目中使用Retrofit/OkHttp，最近我发现了RxJava。将它与Retrofit结合起来似乎简单明了，但是在success(...)中的Retrofit中有规律的异步回调，我们正在接收解析的POJO和响应。这是非常有用的，在我的回调中，我使用了这两个对象。我似乎想不出用RxJava做这件事的方法。
是否可以同时获得解析的POJO和响应对象？
浏览 3提问于2014-09-25得票数 1
回答已采纳
我发现了很多关于错误的文章，我知道我们只能从主线程更新UI。让我告诉你我所犯的全部错误：
E/RxEroor: The exception could not be delivered to the consumer because it has already cancelled/disposed of the flow or the exception has nowhere to go, to begin with. Further reading: https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0#
浏览 5提问于2020-12-24得票数 0
回答已采纳
我有一个绑定服务，负责下载文件，因此它知道下载状态/进度。UI (片段或活动)必须显示/更新服务的下载进度。
实际上，我认为常用的方法是使用活动中的BroadcastReciever或CallBack。但是，我听说过使用RxJava (ReactiveX编程)和中介类(以及Dagger将其注入服务和活动中)，如下所述。
所以我的问题是如何处理这些东西的RxJava？有密码样本吗？还有比使用意图更有效的方法吗？
资源：参见第一个应答更新
浏览 0提问于2015-11-20得票数 18
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
4回答
有很多关于RxJava的很棒的文章。但几乎所有这些都没有用现实世界的例子来解释这个概念。
因此，我基本上理解了RxJava Subject的概念，就像一个管道，它既是observable又是observer。
但我看不出这款RxJava Subject在安卓开发领域的实际使用情况。你能详细说明一下吗？
浏览 6提问于2016-12-14得票数 11
2回答
我使用RxJava来观察几个按钮的点击情况。
这些订阅将在一个花费数毫秒时间的对象上调用不同的函数。这些功能是同步的。
问题是，当太多的按钮被按下，我得到一个背压异常。对我起作用的是放弃几个输入(最好是旧的)。这与RxJava是可能的吗？
浏览 4提问于2015-12-14得票数 1
回答已采纳
我目前正努力让自己进入RxJava。
现在我有了以下场景：
我必须对用户进行身份验证。
为此，我需要做的步骤如下：
尝试使用本地存储的令牌验证用户
如果身份验证失败(由于令牌过期)，请尝试使用本地存储的刷新令牌获取新令牌。
替代品：
关于成功：
本地保存新获取的令牌
再次尝试验证，如果失败，则显示错误。
- On failure (because also the refresh token expired): Show login dialog
- On failure (because of other reasons): Show err
浏览 1提问于2016-11-17得票数 1
回答已采纳
我有一个非常简单的RxJava示例
List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5));
Observable.fromIterable(arrayIntegers).map(i -> {
Log.d("RxJava", "map i = " + i);
return i;
}).subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainT
浏览 4提问于2017-11-01得票数 0
回答已采纳
我试图添加触摸处理程序到，但似乎这样做，我不能再草图。的确，FabricView本身定义了一个Touch处理程序，但我的尝试--使用RxAndroid2 --似乎清除了预定义的处理程序，而不是链接到它。
我想要的是能够使用我的处理程序，而不清除现有的处理程序。
这是我主要活动的一部分(草图视图是FabricView的一个实例)
sketchView.backgroundMode = FabricView.BACKGROUND_STYLE_NOTEBOOK_PAPER
RxView.touches(sketchView, {_ -> true}).subscribe { // se
浏览 0提问于2017-07-09得票数 2
回答已采纳
我正在将一个Android Studio项目从使用RxJava 1.x切换到RxJava 2.x，并试图尽可能少地更改功能。该项目使用了Observables，在RxJava 1.x中是背压的。在RxJava 2.x中，Observable不再是背压的，但Flowable是，所以我将Observable的用法转换为Flowable的用法。但是，Flowable.create要求我指定一个。既然我想保持相同的功能，那么Observable在1.x中使用哪种策略呢？
浏览 0提问于2017-02-03得票数 3
有办法在一个项目中同时使用RxJava和RxScala吗？
import rx.lang.scala.{Observable => ScalaObservable}
import rx.{Observable => JavaObservable}
我们有一个用Java编写的模块，它使用JavaObservable (RxJava)。然后我们有一个Scala模块，它应该使用Java模块，但它是用Scala编写的。
是否有方便的方法将这些转换成另一种？
浏览 1提问于2016-02-08得票数 4
回答已采纳
1回答
安卓RxJava2手柄方向改变
、、、、
我是这个图书馆的新手，所以如果你有任何建议或建议，我们非常欢迎。我让RxJava2运行并执行一个longNetworkOperation假方法，流程如下：
创建可观察的: Observable.just("str1")
更改执行线程：.subscribeOn(Schedulers.newThread())
实现映射接口，它将执行LongRunningProcess：
.map(new Function<String，String>() {@String>公共字符串应用程序( String cad )){ // cad是输入值Log.d(标记，线程中
浏览 4提问于2017-06-08得票数 1
回答已采纳
我想知道如何通过Retrofit2测试rxjava2调用。我的改进api接口如下所示：
public interface LoginApiMapping {
@POST("v1/secm/oam/oauth2/token")
Observable<Response<RestResponseHolder<LoginResponseModel>>> login(@Body LoginModel model);
}
我想写一个测试，它将通过RxJava2发送这个请求并检查响应。我认为RxJava存在问题，因为它是异步的，并且测试在得到响
浏览 6提问于2017-03-17得票数 4
回答已采纳
下面的MissingBackpressureException发生在OperatorOnBackpressureDrop应用于OperatorObserveOn之前
rx.exceptions.MissingBackpressureException
at rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.onNext(OperatorObserveOn.java:162) ~[rxjava-1.1.10.jar:1.1.10]
at rx.internal.operators.OperatorOnBackpressur
浏览 3提问于2016-10-18得票数 1
回答已采纳
1回答
我对RxJava还很陌生，正在努力学习如何组合可观察对象。
我需要发出2个请求(独立)，并从2个REST服务检索2个模型。
下一步是从前面的两个模型中创建第三个模型。
下面是我的两个观察值和一个函数：
Observable<ProfileModel> userProfile(@Path("token") String token);
Observable<OnDemandRules> getRules();
Func2<OnDemandRules, ProfileModel, UserDetails> createUserDetails(fi
浏览 0提问于2015-01-19得票数 1
我有一个API，它只返回错误/成功代码，没有主体。使用RxJava1，我将使用Observable<Void>作为此调用的返回值。
我能用什么做RxJava2呢？关于Wiki for RxJava2 ()的提示是没有帮助的，因为我无法改变API的工作方式。
设置：
compile 'com.squareup.retrofit2:retrofit:2.1.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'
compile 'com.jakewharton.retrofit:retro
浏览 2提问于2017-02-07得票数 7
回答已采纳
1回答
JSON
[
{
"countryName":"..."
},
{
"countryName":"..."
},
{
"countryName":"..."
} //etc... to 195 countries
]
接口
public interface RetrofitInterface {
@GET("GetCountries.php")
Single<List<Country
浏览 10提问于2021-12-30得票数 0
当我使用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
我有两个不同对象的列表，称为使用Retrofit2。这两个列表工作正常，并返回所有元素OK。第二部分是两个对象都有一个属性"importe“(表示货币)，因此首先我需要将每个列表的对象相加为一个小计，然后将这两个列表的小计相加以得到总计(totalList1 + totalList2)，并在TextView中显示这个值。
我的问题是，由于我使用两个异步请求，所以无法对小计进行求和。我的代码可以找到。
我尝试使用retrofit2同步请求，但得到了一个错误：
android.os.NetworkOnMainThreadException
所以其他人建议我使用RxJava。有人能详
浏览 1提问于2017-07-25得票数 0
回答已采纳
1回答
我试图将rxJava与我已经知道的东西联系起来，特别是从JavaScript编程中。rxJava的核心理念是否就像可观察到的承诺一样？
浏览 0提问于2015-04-30得票数 3
回答已采纳
我是RxJava的新手，我需要创建包含多个数据源的存储库。这对我来说很复杂，因为有几个较小的子任务我不知道如何用RxJava实现。 我有Dao，它为DataSource类提供了一定范围内的Flowable<Item>。此数据源具有可随时失效的本地缓存。当存储库向DataSource请求某个范围(可能超出DataSourse范围，直到完全缓存才知道边界)时，它必须产生一个错误(或者以其他方式通知存储库)。 我想为DataSource创建Flowable<Item>方法，它将从缓存中发出项，如果需要，可以将它们与Flowable<Item> dao.getRa
浏览 17提问于2019-05-27得票数 0
回答已采纳
我在我的应用程序中使用了两个模型：
DatabasePresenter (UI)
安卓寻呼给我一个DataSource.Factory<*, DatabaseModel>
@Dao
interface ProjectDao {
@Query("SELECT * FROM project")
fun getAllProjects(): DataSource.Factory<Int, DatabaseModel>
...
}
当我想使用LiveData制作LivePagedListBuilder(dataSourceFactory,
浏览 2提问于2020-06-06得票数 2
回答已采纳
我正在使用RxJava并遇到以下问题。
threw exception [Request processing failed; nested exception is java.lang.IndexOutOfBoundsException: Index: 0, Size: 0] with root cause
rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: [Ljava.lang.Object;.class
at rx.exceptions.OnErrorThrow
浏览 0提问于2018-05-28得票数 0
回答已采纳
我是RxJava2的新手，我使用了defer、concat和create等其他方法。我正在努力寻找一种实现上述内容的方法。
具体的需要是，我有一个片段，显示和隐藏。这个片段有subscribers到EventBus事件。这些事件是由我一直在后台运行的服务触发的。
当碎片被隐藏时我不想失去他的排放。相反，我想以某种方式cache在隐藏时发出的排放物，然后在显示片段时释放它们。
是否有使用RxJava2 API的内置解决方案？
浏览 0提问于2017-01-31得票数 0
回答已采纳
2回答
我用的是Rxjava和Retrofit。我知道如何使用它，但我仍然不清楚“Rxjava对Retrofit到底做了什么”。
我们对REST调用使用任何转换器(如Gson)和Okhttp库进行改造，一旦得到响应，它就具有可观察的类型(如果使用Rxjava，否则它将是调用类型)。现在的问题是，如果我们已经得到响应，那么Rxjava究竟是如何处理这个响应的呢？
到目前为止，通过查看代码，Rxjava首先采用了可观测响应，然后使用操作符对进行了一些操作，已经得到了响应，然后它只将最后的响应发送给观察者，从那里可以将数据膨胀成视图。
首先，如果我对Rxjava的理解是错误的，请告诉我。
对进
浏览 0提问于2017-09-11得票数 0
回答已采纳
RxJava2CallAdapterFactory.create()的作用是什么？
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("https://api.example.com")
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
浏览 1提问于2017-08-24得票数 5
2回答
我们能否检测到一个类成员值是否正在使用RxJava进行更改？？假设在一个类中有一个变量var，那么当var的值使用RxJava发生变化时，我们可以得到通知吗？
浏览 6提问于2016-07-05得票数 9
回答已采纳
1回答
当我们在RxJava中使用观察者时，我想知道内部到底发生了什么，以及订阅者如何从观察者那里获得所有数据流。
提前感谢你们所有人。
浏览 4提问于2017-07-12得票数 0
这是我在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
回答已采纳
2回答
创造一个主题
、、、
我在RxJS中见过这种情况，但在RxJava中还没有找到类似的。有人知道如何在java中设置这样的东西吗？
从指定的观察者创建一个可观察的主题。
参数
观察员(观察员)：观察员用来向主题发送信息。
可观察的(可观察的)：可观察的用于订阅从主题发送的信息。
基本上，这将是一个主题，您可以通过它将数据发送到另一个观察者，并有一个可观察的，它将数据发送回主题订阅者。
我正在尝试复制在 in RxJava中看到的代码。
浏览 2提问于2015-01-20得票数 2
回答已采纳
我不清楚如何在RXJava中实现任务取消。
我对移植使用番石榴的ListenableFuture构建的现有API很感兴趣。我的用例如下：
我有一个单一的操作，由Futures.transform()加入的一系列期货组成
多个订阅者观察操作的最终未来。
每个观察者都可以取消最终的未来，所有的观察员都可以见证取消事件。
最终未来的取消将导致其依赖项的取消，例如，在序列中，3的3取消被传播到2，等等。
RxJava wiki中几乎没有这方面的信息；我可以找到的唯一可以取消的引用都提到了Subscription相当于.NET的Disposable，但据我所见，订阅只提供了从序列
浏览 4提问于2014-08-16得票数 14
回答已采纳
2回答
我已经看到一些RxJava项目使用.subscribeOn(Schedulers.io())多线程，它们的.subscribe(() -> {...})代码正在操作其他可观察到的订阅处理程序也处理的一些数据结构，而且subscribe中任何地方都没有synchronized()。
来自C/C++，我开始怀疑-等等，如果那些subscribes碰巧在不同的线程上执行，那么竞争条件呢？
在C/C++中，它迟早会崩溃并烧坏一些访问权限。当然，Java似乎要宽容得多。但是，如果两个subscribes碰巧并行地处理相同的链接列表，该怎么办？他们不会搞乱节点之间的链接吗？我不应该用synchron
浏览 0提问于2020-07-01得票数 1
我有两个单打，定义如下。
Single<User> userSingleA = Single
.fromCallable(()-> {
// Function fetching user data from mirror A
return user;
});
Single<User> userSingleB = Single
.fromCallable(()-> {
// Function fetching user data from mirror B
浏览 1提问于2018-03-06得票数 2
回答已采纳
我是RxJava新手，并尝试使用领域可观察特性。
做这件事的时候
realm.where(Intake.class)
.findAllSorted("time", Sort.DESCENDING)
.asObservable()
我得到了完整的项目列表，但当更改时(即添加项目)，我将再次获得完整的列表。
什么是RxJava的方式，只获得新的项目？
提前感谢
浏览 3提问于2016-04-23得票数 1
回答已采纳
1回答
对于RxJava来说，我对接口回调(通过接口变量从内部层/代码模块调用)和RxJava有疑问。为了使它更清楚，快速的例子：
标准回调接口实现、接口、A类和B类
interface CustomCallback {
void onCallbackCalled(String str);
}
class ClassA {
private ClassB classB;
public ClassA() {
classB = new ClassB(new CustomCallback() {
@Override
pub
浏览 2提问于2017-05-06得票数 3
回答已采纳
根据RxJava文档，interval运算符“创建一个可观察到的序列，它发射出一个由给定时间间隔间隔的整数序列”。我编写了下面的程序，但是订阅方法没有被调用。我在这里漏掉了什么吗？
Observable<Long> observable = Observable.interval(1, 1, TimeUnit.SECONDS);
observable.subscribe(new Consumer<Long>() {
@Override
public void accept(Long t) throws Exception {
Syst
浏览 0提问于2019-01-30得票数 0
回答已采纳
2回答
我有一个来自API的GET请求。使用Retrofit和RxJava，我得到了一个响应。现在我想将我的响应添加到Room数据库。但是我不想用AsyncTask，我想用RxJava。我在Dao insertAll中准备了一个方法。如何使用RxJava将我的列表异步添加到数据库？我的get请求： @GET("contacts")
fun getContactModel(): Single<List<Contact>> 我的Dao insertAll方法： @Insert(onConflict = OnConflictStrategy.REPLACE)
fun
浏览 35提问于2020-01-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
