Override public void onNexte.toString(),"MyTAG"); public void onComplete() {
});调用RequestHelper.GetRequest成功(查看后台日志，调用成功后返
浏览 5提问于2017-12-16得票数 0
1回答
我是RxJava的新手，我的印象是，每个活动都会通知每个订阅者。因此，如果我们有N个订阅者和X个事件流，将调用N个订阅者中每个订阅者的onNext。("Hello"); emitter.onNext("Bar");
浏览 19提问于2021-06-11得票数 0
回答已采纳
我正在使用RxJava2开发一个安卓应用程序(这并不重要)，在一些单例应用程序中有一些PublishProcessor。而且在整个项目中都有很多.onNext()调用这些PublishProcessor。现在，为了进行调试，我需要知道，在每个被调用的.onNext()上，我的项目中的哪一行调用了这个.onNext()。
在RxJava(2)中是否有一种方法可以实现这一点？
浏览 1提问于2019-07-16得票数 2
回答已采纳
在调用onNext之后，我希望发出一个随机值10秒。因此，12345和10秒后将调用onNext，随机数应该调用onNext。使用RxJava实现这一目标的最佳方法是什么？提前谢谢。Observable.create(subscriber -> {}).subscribeOn(...).subscribe(new Subscriber<Long&
浏览 2提问于2017-01-30得票数 3
回答已采纳
我是rxjava的新手。implementation "io.reactivex.rxjava2:rxjava:2.2.8"我和interval()一起工作，Obse
浏览 0提问于2020-08-19得票数 0
回答已采纳
$2.onNext(OperatorOnBackpressureDrop.java:98) ~[rxjava-1.1.10.jar:1.1.10] at rx.subjects.PublishSubject$PublishSubjectState.onNext(PublishSu
浏览 3提问于2016-10-18得票数 1
回答已采纳
2回答
我在zip中组合了多个观察者，以执行来自服务器的多个请求，但onNext没有执行，因此我无法获得返回值。menuName、restaurantName和userName是全局变量。Log.e("Eatright Error", d.toString()+""); public void onNext/api/account/user/{id}")
Observable<
浏览 0提问于2017-04-17得票数 0
我在Subject中创建了一个RxJava实例，并从多个线程调用它的onNext()：subject.onNext("A"); //thread A说：
注意不要从多个线程调用它的
浏览 3提问于2015-08-05得票数 11
回答已采纳
onError- " + e.getMessage()); public void onNext(NewChatModel model) { apiCallingNewChat();
浏览 1提问于2018-01-30得票数 5
2回答
有没有一种RxJava连接观察者的方式？Object>() { // ... } @Override observer1.onNext(event); // ...以便观察者链接在一起(当原始onNext()被<
浏览 0提问于2016-10-15得票数 1
这是我在Kotlin的测试代码： rxjava() val queuSubject = PublishSubject.createRxCachedThreadScheduler-2thread in subscription RxCachedThreadScheduler-2
如您所见，调用subscribeOn对PublishSubject's流没有任何影响，thread-0,thread-1 and t
浏览 2提问于2021-07-02得票数 1
回答已采纳
2回答
RxJava2观察者不支持在onNext函数中省略onNext。 at retrofit2.adapter.rxjava2.BodyObservable$BodyObserver.onNext(BodyObservable.java:51)
at retrofit2.adapter.r
浏览 10提问于2017-03-06得票数 2
回答已采纳
我有一个数据库，可以在RxJava链工作的过程中进行更新。RxJava链如下所示： .subscribeOn(Schedulers.single(.concatMap(/*Mapping*/) .subscribe(/*Consumers*/)
当RxJava因此，Flo
浏览 0提问于2018-10-17得票数 0
回答已采纳
我在使用下面提到的库调用API时遇到了一个问题。-adapter:1.0.0'compile 'io.reactivex.rxjava2:rxjava:2.0.1("form/{slugOrUUID}")
Observable<CoreObject> getForumRx(@Path("slugOrUUID") String s
浏览 4提问于2017-01-24得票数 4
根据 的说法，在RxJava中，这是经过设计的。必须处理每个GroupedObservable才能使toList操作符工作。
浏览 5提问于2015-04-04得票数 0
回答已采纳
emitter.isDisposed()) { emitter.onNext(i默认情况下，RxJava是否运行相同线程上的代码发射值(可观测值)和代码接收值(观察者)？
浏览 0提问于2021-01-03得票数 0
回答已采纳
1回答
我想用RxJava在WebView中实现单击删除。首先，我认为throttleFirst对此很有好处。throttle events and return something() if it's ok or return just true for debounced events当具有像RxJava这样的返回类型的方法时，如何使用shouldOverrideUrlLoading返回值
或者我不应该在这种情况下使用Rx？
浏览 4提问于2015-02-17得票数 1
我正在运行RxJava并创建一个使用onNext()方法生成数据的subject。我正在使用Spring。safeSource.subscribe(new Subscriber<AsyncRemoteRequest>() { public void onNext(myObj);}
在RxJava流上生成新数据的方式是@Autowire private SubjectObserver subjectObserver，然后调用</em
浏览 3提问于2016-10-25得票数 1
回答已采纳
我使用的是observables和rxJS库。this.validate$ = new Observable(observer =>然后我将对象推到上面，如下所示：如果我正在获取的内容中存在错误，我会按如下方式传递该错误：我从一个不同的类按如下方式订阅：
this.
浏览 0提问于2016-03-03得票数 1
在给定Observable和Subject的情况下，使用RxJava3，我可以为可观察对象订阅主题： observable.subscribe(subject); // returns void, not
浏览 13提问于2020-07-14得票数 1
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
