我是RxJava新手，遇到了一个问题。下面是我获取A列表的代码： .subscribeOn(Schedulers.io()) .subscribe(list -&g
浏览 0提问于2016-09-03得票数 0
在什么情况下需要在RxJava中使用RxJava？ .subscribe(line -> System.out.println(line)); .subscribe(line -> System
浏览 3提问于2020-06-10得票数 0
回答已采纳
当我使用Observable.subscribe()时，通常返回Disposable。根据introtorx.com的说法，Observable.subscribe(Obeserver)返回Disposable。为什么rx和rxjava不同？我在Andr
浏览 5提问于2017-06-16得票数 6
当通过这些API调用发送大量数据时，我在每个threads.But中都有多个API调用，app运行得更慢，有时甚至API响应failure.Is也有更好的方法来执行此任务或在可能的情况下依次运行这些线程
浏览 2提问于2019-08-14得票数 1
我使用RxAndroid在我的应用程序中执行计时器任务。使用Observable.interval()执行此操作。一切都很正常，但我需要停止活动的onDestroy()中的计时器。这是我正在使用的代码： .flatMap(n -> mObservableNewChat.subscribeOn(Schedulers.io())
.observeOn(AndroidS
浏览 1提问于2018-01-30得票数 5
1回答
在rxJava 1.x中，可以这样做： ...getNewObservable().subscribe(Subscribers.wrap(subscriber));GetNewObservable()还返回Observable<Foo>
我在rxJava 2中找不到相同的方法。在可观测对象上没有
浏览 2提问于2017-04-10得票数 2
回答已采纳
2回答
等效于RxJava
、、、
我们可以在C# Rx中异步执行一些代码，如下所示，使用Observable.Start()。我想知道在RxJava中什么是等价的。void Main() AddTwoNumbersAsync (5,4)IObservable<int> AddTwoNumbersAsync(int a, int b) return Obs
浏览 3提问于2015-01-12得票数 2
回答已采纳
因此，我试图用RxJava在android中实现MVI模式，但我想在状态下处理抛出的error，以及成功和加载，是否存在处理错误而不是来自subscribe(onError = xxx)的错误？ObservableTransformer<AuthAction, AuthResult> { actions -> Observable.mergeSignInWithGoogleAction::class
浏览 1提问于2020-06-03得票数 0
回答已采纳
我正在尝试用RXAndroid创建一个重复的后台计时器。我已经编写了在后台以指定时间间隔执行的代码，但我无法找到阻止它的方法。public void onError(Throwable e) {}
public void onComplete() {}
.subscrib
浏览 0提问于2017-10-30得票数 0
回答已采纳
2回答
创造一个主题
、、、
我在RxJS中见过这种情况，但在RxJava中还没有找到类似的。有人知道如何在java中设置这样的东西吗？
从指定的观察者创建一个可观察的主题。我正在尝试复制在 in RxJava中看到的代码。
浏览 2提问于2015-01-20得票数 2
回答已采纳
3回答
嗨，我正在努力学习rxjava2。我试图使用rxjava2调用API，并使用改进来构建URL并将JSON转换为Moshi。
override fun doServerLoginApiCall(email: String, password: String): Observable
浏览 3提问于2017-10-23得票数 0
回答已采纳
我正在尝试用RxJava编写我的第一段代码，但我想我遇到了一些库导入错误。package second.pack;public class Main { Observable <String> observable = Observable.create(
// the line below marked
浏览 0提问于2018-06-28得票数 0
回答已采纳
1回答
如代码所示，我正在尝试创建一个Action，然后将它传递给订阅方法，但是在下面的代码流中我会收到错误： //Error message: cant resolve methodimport io.reactivex.functions.Action;compile 'io.reactivex.rxjava
浏览 6提问于2017-10-02得票数 0
因为我是RxJava新手，所以尝试运行以下代码，但它向我展示了代码如下 @Overridesubscriber.onError(e); // In case there are n
浏览 15提问于2018-01-11得票数 4
回答已采纳
TL;DR:我想执行多个Calls (Retrofit)，就像您可以.zip()多个Observables (RxJava2)一样。price")我可以用enquene()在代码中执行我知道我可以开始使用Observable (RXJava2)而不是Call (Retrofit2
浏览 1提问于2019-08-29得票数 5
回答已采纳
4回答
如何将数组转换为可观测的
、、、
但我面临两个问题：2-为什么在观察者的接口中没有实现onSubscribe(Disposable d)？构建分级compile 'io.reactivex:rxjava:1.1.9'import rx.Observableimport rx.functions.Func1;
浏览 0提问于2018-07-17得票数 2
()) .subscribe(asyncSubject)asyncSubject.subscribe{}impleme
浏览 16提问于2019-07-07得票数 0
1回答
我一直在尝试学习如何使用RXJava，我想知道如何更改下面的AsyncTask代码并使用RXJava，这是可能的吗？我是RXJava的新手，由于AsyncTask已被弃用，因此我需要一些帮助。
浏览 20提问于2020-04-18得票数 3
回答已采纳
1回答
我使用RxJava 1已经有一段时间了，但我想看看RxJava 2。在RxJava 1中，我可以像下面这样发出列表的每一项： .filter(str -> str.contains("Help")但是，我如何使用RxJava2实现同样的目标呢我试着使用下面的代码，但是我似乎不
浏览 1提问于2017-01-09得票数 7
回答已采纳
2回答
Udpate，根据Anton的回答，我已经尝试了以下方法： compile 'io.reactivex:rxjava:1.0.+'
Observable<PlaceD
浏览 0提问于2016-04-04得票数 12
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号