我将它包装在一个可观察对象中，并将其传递给一个映射它的服务，然后通过活动调用该服务。我遇到的一个问题是，当我启动新的Observable并调用事件时，事件被返回，但随后被作为null传递给Observable.next，这导致我的应用程序崩溃。.get("primary", eventId)
observer.
浏览 39提问于2020-04-16得票数 0
我正在使用RxJava2实现具有2级缓存的简单数据提供程序 Observable.concat(getFromMemory(e -> { e.onNext(1);Source: MemorySource
浏览 2提问于2017-05-16得票数 1
我在RxJava操作符上做实验，发现了这个问题，不知道为什么会这样。让我来举一个例子，希望问题会很清楚。我有一个可以观察到的水果，我用Observable.just创建了它
Observable<String> fruits = Observable.just("Apple", "Banana", "Mango", "Strawberry", "Raspberry", "Blood Oranges&qu
浏览 0提问于2019-01-20得票数 1
回答已采纳
2回答
有一点上下文:在这个链接中： @ben提出了一种使用可观测值进行轮询的手动递归实现。然而，在最新的RxJava版本中，没有OnSubscribeFunc。以下是我目前的实现： @Override in
浏览 6提问于2015-12-24得票数 3
回答已采纳
我是kotlin的新手，我正在尝试在MVVM体系结构中使用Rxjava和实时数据的改进。我配置修改，并在ViewModel中使用可观察和订阅来使可观察的变量用于活动绑定布局。我的视图中有一个按钮，当我单击它时，request方法将开始并订阅它自己的数据的日志。但是我的变量在一开始和几秒钟后获得null，当更新完成它的任务时，我的变量会获得数据，但是日志值不会更新。= null)
iDataTransfer.onSucce
浏览 2提问于2020-05-24得票数 0
我是RxJAVA的初学者。我想给另一个线程分配一个初始化作业，并在它完成时通知我，这样我就可以开始工作了。因为这个可观察的没有任何数据要发出，所以我使用了中讨论过的Void。我想问一下，我是在这个场景中使用Void，还是RxJAVA有更好的方法来满足这种需求？这是我的代码： @Override
public void subscribe(Obs
浏览 2提问于2017-03-01得票数 0
回答已采纳
1回答
我正在使用Retrofit和OkHttp3，以及用于异步的RxJava2。 我应该在Retrofit服务的返回值中使用除Single以外的其他值吗？通常情况下，可观察值发生变化并再次调用onNext，但在REST中，当请求成功时，onNext只被调用一次。
浏览 6提问于2019-01-06得票数 1
我正在研究RxJava。我为可观察的类创建了一个真值和假值的随机布尔流。 val apiResultStream = Observable.create(object : Observable.
浏览 0提问于2020-03-30得票数 0
3回答
我有一个可以观察到的东西，它不需要发出一个值。此外，我有一个对象的列表，我希望可以观察到的工作。}以及创建可观察到的方法： return Observable.createsuper Void> subscriber) {
浏览 1提问于2015-07-23得票数 13
回答已采纳
我探索了在RxJava中创建新的观察者的不同方法。 ( interface Observable.OnSubscribe<T> )失败了。
浏览 1提问于2018-06-28得票数 1
回答已采纳
1回答
我在rxjava中调用下面的函数来获取顶级新闻： returnpublic Observable<Integer> call(final List<ContentValues> stories) { public Observable<ContentVal
浏览 0提问于2018-04-11得票数 0
回答已采纳
我有这样一个可以观察到的我有这个密码 });
repoNames只是一个字符串列表当我手动添加字符串"hello“时，onNext将被调用，但是当我从API调用中添加字符串时，如下
浏览 0提问于2018-12-07得票数 0
回答已采纳
此外，当数据被加载到某个片段/活动中时，我需要接收一个事件。 Observable.create(emitter -> { Data next = getDataFromDb();
emitter.onNext</
浏览 5提问于2017-12-12得票数 0
回答已采纳
我有一个名为Student的类，它有两个字段grade和school。这两个字段都需要从远程服务器获取。当两个结果返回时，我新建了一个Student对象。在RxJava的帮助下，我以两种方式完成了它，一种是在flatMap中，另一种是在zip操作符中。Observable<String> gradeObservable =
Observable.create((ObservableOnSubscribe<String&
浏览 0提问于2018-03-08得票数 5
回答已采纳
().getName() +}
log("Emitting "+ i);
emitter.onNext(i第一个是传递给Observable.create
浏览 0提问于2021-01-03得票数 0
回答已采纳
但是，当我试图用RxJava实现这一点时，我很难处理它。因为我不能在观察者中将任何参数传递给onComplete。因此，我最终得到了以下实现。我将ProgressInfo和Result的通行证合并为onNext。Observable.create(emitter -> { emitter.onNext(progressInfo因为任务最终只是试图做一些计算，并
浏览 6提问于2020-06-08得票数 2
回答已采纳
2回答
我在我的安卓项目中使用RxJava，实际上我正在开始测试我的代码。我有一个可以观察到的方法，我要测试 return(subscriber -> { testString = "CHANGEDSTRING"
subscriber.onNext(subscrib
浏览 2提问于2016-09-07得票数 0
回答已采纳
我对rxjava有一个非常具体的问题或误解，希望有人能帮上忙。我正在运行rxjava 2.1.5，并有以下代码片段： // Code ...
observable.subscribeOn(Schedu
浏览 1提问于2017-10-25得票数 3
回答已采纳
我有一个类Producer，简化它有public Object readData()方法，我想把这个类变成Observable ()。下一个问题是readData应该每n秒钟调用一次()。有些方法，例如，有调度器参数，但是我找不到如何应用它的例子。我找到了方法，但它发出一个整数序列。
浏览 4提问于2013-12-13得票数 6
回答已采纳
2回答
我想使用Observable 2创建一个RxJava from视图单击监听器。Observable<View> viewObservable = Observable.create(new ObservableOnSubscribe<View>() { e.onNext(value); }});
浏览 6提问于2017-04-07得票数 24
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
