我将一个简单的get方法发送到我的服务器，并使用RxJava和Retrofit获得结果。我做的事情是：public interface Posts {
Observable<List<Beans>> getPostspath") String path);RetrofitInstance
浏览 18提问于2019-07-30得票数 0
1回答
我在用Retrofit2+RxJava。当我发出请求时，服务器可以返回两种响应中的一种，Succes和Error，但在这两种情况下，HTTP状态代码= 200。当我让Erron进入响应体而不是调用onNext调用onError时，如何实现这一点？Please check your internet connection"); });
我的端点接口
浏览 1提问于2017-01-10得票数 1
回答已采纳
我有这样的密码： }) private PublishSubject<Location
浏览 1提问于2018-06-21得票数 0
回答已采纳
1回答
我有一个这样的A类： id: Long event: Event id:Long}aService.getA(id)
然后，对于结果(有一个null事件)，使用eventId检索适当的Event (eventService.getEvent())，将其赋给A.event，然后返回我尝试使用flatmap返回Event，但随后丢失了来自A的</
浏览 15提问于2018-01-18得票数 0
回答已采纳
1回答
在第一个名为LoginActivity的活动中，这个活动用于登录到app。，实际上我已经通过gson向客户端返回了所需的信息。现在我想通过rx将这些信息存储在设备中，我已经通过rx完成了登录任务，当服务器返回用户信息时，我在onNext中获得了以下信息：
.switchMap(new Function<Response这就是我在数据库中插入我的模型时可以观察到
浏览 1提问于2018-04-01得票数 0
回答已采纳
(这个问题是在Android环境下提出的，但只有Kotlin知识才能回答。) } }
}如您所见，只有onNextoverride fun onNext
浏览 0提问于2018-05-28得票数 2
回答已采纳
因此，在我的视图模型中，我在另一个类中调用了我的Observable： .subscribeOn(Schedulers.newThreadR.string.error_cannot_authenticate)); public final void onNextmSub
浏览 0提问于2016-12-02得票数 0
我正在尝试制作一个使用谷歌架构组件的Android应用程序。我在Repository类中使用retrofit和rxjava向TasteDive API发出请求。我目前正在做的是，我有一个名为Outcome的密封类，用于跟踪请求的状态，在这个密封类中，我有一个数据类，用于保存成功请求的数据。当我尝试将结果赋给LiveData时，不出所料，它返回null，因为obse
浏览 2提问于2018-09-19得票数 0
我有一个可以观察到的片段，它最终要么返回一个错误并重试，要么只返回onNext。我不需要onNext中的任何东西，所以这只是一个Observable<Unit>。现在的问题是，在链的末尾，我必须点击这个onNext，除了好的旧Observable.just()之外，我没有别的东西。但是我不能返回Observable.just(null)，因为它
浏览 2提问于2017-03-01得票数 8
回答已采纳
2回答
我有一个自定义类，叫它Builder。它有一个方法act()，它执行异步操作。操作完成后，我想发出一个事件。 class Builder processRunner.runAsynconComplete(int result) {
&
浏览 1提问于2016-09-19得票数 0
回答已采纳
1回答
我有一个关于JAVA-多线程的问题。webapp是用jsf构建的。因为我有一个控制器，它调用一个处理程序类来启动流： if(streamHandler!is running: "+String.valueOf(activatedStream));
FacesContext.getCurrentInsta
浏览 4提问于2017-04-27得票数 0
我使用MVVM模式创建了一个小的、向导风格的示例应用程序(基本上是我的“真实”应用程序中代码的简化版本)。在这个应用程序中，主窗口通过视图模型的List<..>移动，每个视图模型都显示其关联的视图。我有两个视图模型类，它们本质上是相同的，它们显示相同的视图。
视图上有一个组合框，其中填充了一个浮点数数组。SelectedItem绑定到视图模型<
浏览 1提问于2012-03-30得票数 2
回答已采纳
所以重点是，它为订阅者保留一个弱引用，每次事件触发--它获取订阅者的委托并触发该委托，但是如果他不能从弱引用中获得一个对象，那么它就会处理到委托的链接。问题是，经过很短的时间后，弱引用返回null (但订户仍然活着)，然后执行对链路的处理。所以我的问题是为什么会发生这种情况，以及如何解决这个问题？如下所示：(请看代码中的注释)
private static IDisposable InternalSubscr
浏览 1提问于2016-11-29得票数 4
回答已采纳
我正在使用grpc项目中的类来设置一些双向流。当我运行我的程序时，我会向服务器发出数量未定的请求，并且我只想在完成所有请求之后在requestObserver上调用requestObserver()。目前，为了解决这个问题，我使用一个变量"inFlight“来跟踪已经发出的请求，当响应返回时，我会减少"inFlight”。所以就像这样。StreamObserver类中是否有允许这类功能的东西，而不
浏览 3提问于2017-05-03得票数 0
回答已采纳
1回答
我有一个具有多个订阅者的发布主题：class Real {
for (i in 1 until 20) {Subscriber1 19 Hello
Subscriber2 19 Hell
浏览 2提问于2020-05-05得票数 0
1回答
我可以向next按钮添加一个单击处理程序，但这不会等待异步调用返回并继续进行。。在html模板中，我需要按钮：在构成部分中： let promise = service.validateData()有使用 step属性的方法吗？
浏览 3提问于2017-11-01得票数 4
回答已采纳
我有几种不同类型的传入事件，我希望将它们分派给不同的IObservables，它们作为属性公开，但不多次订阅底层UDP。(e as TimeEvent); break;var dispatcher = new EventDispatcher(mock.Object);
subject.OnNext
浏览 4提问于2012-05-09得票数 2
回答已采纳
1回答
我们有一些类，它有一个返回一些值的方法： Observer<File> fileObserver; // implement logic in Observable<File> and return value which was
浏览 0提问于2015-06-20得票数 11
回答已采纳
我使用Rxjava和Retrofit来处理来自HTTP服务器的响应。大多数情况下，数据响应都采用这种格式： code: 'OK',}{}
我做了一个BaseResponse类。null，但这在中是不允许的。在Customize观察者中，我处理onNext()中的所有onNext场
浏览 4提问于2017-04-30得票数 3
回答已采纳
我想要一个不做任何事情的Observable，当订阅时，会调用观察者的onNext回调函数。我想我在Observable.empty()中发现了这一点，但是下面的代码并没有导致观察者的onNext回调被调用：
@Override public
浏览 0提问于2015-03-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
