2回答
RxJava忽略onNext
、、、、
有什么办法可以忽略onNext方法吗？))但是得到了错误
java.lang.IllegalArgumentException: onNext
浏览 15提问于2016-09-02得票数 2
回答已采纳
当我需要删除/忽略元素时，如果它是，则需要删除/忽略元素，如果它是当前出现在反应性流中的。: $it") error("$it") publishSubject.onNext(2)
publishSubject.onNext(1) //
浏览 0提问于2019-05-21得票数 0
1回答
我是RxJava的新手，我的印象是，每个活动都会通知每个订阅者。因此，如果我们有N个订阅者和X个事件流，将调用N个订阅者中每个订阅者的onNext。("Hello"); emitter.onNext("Bar"); });
浏览 19提问于2021-06-11得票数 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回答
在RxJava中，背压并不是真正的背压，而只是忽略了一些元素。RxJava不能影响元素发射，所以开发者需要自己实现它。s.isUnsubscribed()) { s.onNext(Math.random());
浏览 2提问于2016-11-12得票数 2
我在RxJava中遇到了一个奇怪的问题，生产者(API request)发出事件的速度太快，而消费者(API response)只得到API请求的第二个响应。startPollingServer();startPollingServer()方法是使用RxJava从服务器轮询数据。) .subscribeOn() .subscribe(
// call onNext// c
浏览 2提问于2017-04-20得票数 0
我是rxjava的新手。implementation "io.reactivex.rxjava2:rxjava:2.2.8"我和interval()一起工作，Observable
浏览 0提问于2020-08-19得票数 0
回答已采纳
我有一个使用RxJava1.x的安卓应用，在使用BehaviourSubject时偶尔会抛出MissingBackPressure。然而，重现异常是极其困难的，所以我尝试编写一个简单的测试，如下所示。$MapSubscriber.onNext(SourceFile:77)
at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext
浏览 12提问于2017-07-27得票数 0
回答已采纳
1回答
protected MySubject(OnSubscribe<R> onSubscribe) { }
@Override public void onNext
浏览 2提问于2014-03-22得票数 0
我只是在学习RxJava，我想将我自己的事件发布到一个可观察的链中。但我在理解主体行为方面有一些问题。(); .subscribe(s -> System.out.println("subject emitted %s", s));
subject.onNext("two");subject
浏览 3提问于2015-10-09得票数 2
回答已采纳
由于我想使用缺乏文档的RxJava2和RxAndroid2来尝试相同的解决方案，所以我尝试了以下方法。}public void setNewData(List<Data> data) {}
我很确定这不是它应该的方式，但是rxjava是否被设计来提供这样的解决方案呢？如果我想共享与onNext、onError、onComplete不同的事件，是否需要在onNex
浏览 2提问于2017-02-20得票数 3
回答已采纳
Index: 0, Size: 0] with root cause at rx.internal.operators.OperatorZip$Zip$InnerSubscriber.onNext(OperatorZip.java:323) ~[/:1.2.0]
at rx.internal.operators.OperatorSubscribeOn$1$1.<
浏览 0提问于2018-05-28得票数 0
回答已采纳
2回答
RxJava2观察者不支持在onNext函数中省略onNext。 at retrofit2.adapter.rxjava2.BodyObservable$BodyObserver.onNext(BodyObservable.java:51)
at retrofit2.adapter.rxjava</em
浏览 10提问于2017-03-06得票数 2
回答已采纳
onError- " + e.getMessage()); public void onNext(NewChatModel model) { apiCallingNewChat();
浏览 1提问于2018-01-30得票数 5
我预计当我将null设置为onNext的参数时，FlowableEmitter会发出错误信号，因为2.0中的不同之处是
以下内容将立即产生NullPointerExceptionFlowable.create(emitter -> { emitter.onNext(null); emitter.onCompleteSystem.out::println,
e -&g
浏览 6提问于2016-09-21得票数 1
回答已采纳
在RxJava1中执行以下操作时，onNext中的异常会重新路由到同一订阅者的onError中： }
public void onNext(String s) {", s + " - " +
浏览 7提问于2017-01-25得票数 5
回答已采纳
我是RxJAVA的初学者。我想给另一个线程分配一个初始化作业，并在它完成时通知我，这样我就可以开始工作了。因为这个可观察的没有任何数据要发出，所以我使用了中讨论过的Void。但是如果我使用Void，我的观察者的onNext和onComplete就不能工作了，我试着用字符串代替，而且它工作得很好。我想问一下，我是在这个场景中使用Void，还是RxJAVA有更好的方法来满足这种需求？Override
public void subscribe(ObservableEmitter<Void> e) throws Exception
浏览 2提问于2017-03-01得票数 0
回答已采纳
我正在使用RxJava2开发一个安卓应用程序(这并不重要)，在一些单例应用程序中有一些PublishProcessor。而且在整个项目中都有很多.onNext()调用这些PublishProcessor。现在，为了进行调试，我需要知道，在每个被调用的.onNext()上，我的项目中的哪一行调用了这个.onNext()。
在RxJava(2)中是否有一种方法可以实现这一点？
浏览 1提问于2019-07-16得票数 2
回答已采纳
1回答
我试图在RxJava的onPostExecute()上实现一个可观察到的/订阅者，但我不知道如何建立连接。我在Observable方法中创建了onPostExecute。super String> subscriber) { @Override
publ
浏览 1提问于2015-05-20得票数 2
回答已采纳
1回答
在RxJava 3中，有什么方法可以将Subscriber订阅到Subject？也是一个Observable，这意味着它应该能够提供上游数据，而其他Subscriber实现(如DisposableSubscriber或DefaultSubscriber)应该能够在Subject的onNext但从逻辑上讲，我想要的是，当主题(也是一个可观察的)发出某种信息时，我可以让订阅者监听，从而调用它的onNext()。
浏览 3提问于2020-07-04得票数 0
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
