回答情况：
提问时间：
问题标签：
我目前正在努力尝试使用rx实现一个tcp watchdog/retry系统，您的帮助将非常感谢。class SocketSubscribeFunc implements Observable.OnSubscribeFunc<Socket> { private final int port;
SocketS
浏览 5提问于2014-03-07得票数 4
我使用Retrofit作为带有Rx-Java的网络库。我想对大多数请求进行一些集中的错误检查，并处理错误，或者如果我不能处理它，就把它传递给订阅者的onError()。我怎么能这样做呢？
浏览 0修改于2017-09-01得票数 3
除了rx-java部分之外，一切都很好。
在订阅中使用观察者，我得到了一个类似这样的错误。
浏览 12修改于2018-01-11得票数 0
回答已采纳
我试着用rx-java的风格来写它。但在代码中，我应该关心当前有多少任务正在运行，然后计算应该从队列中提取多少任务，我认为rx-java应该完成这项工作。
我不确定代码是否可以用一种更简单的方式重写。
浏览 1提问于2016-12-07得票数 0
我有一个PublishSubject，我订阅了两次。第一个订阅者只计算处理的项目的数量，这个值总是与我通过观察者发送的内容相匹配。但是，另一个订阅者正在使用缓冲区，而我通常(75%)不会收到通过观察者的所有项目。我是不是错误地使用了缓冲区？在我停止发送给观察者以确保所有项目都被处理之后，我等待的时间比时间跨度更长。Integer downloads2 = 0;// this subscriber count matc
浏览 0提问于2014-04-17得票数 0
因此，我想使用rx 2进行表单验证。我在用Kotlin。我遇到了两个问题。emailObservable和passwordObservable都是Disposable!型。我试图通过调用val emailObservable: Observable<Boolean>来指定类型，但是Android认为是它的Disposable!。emailObservable和passwordObservable都能正常工作。我刚接触过rx，对这种类型的东西很困惑。
val emailObserva
浏览 0提问于2018-03-15得票数 0
回答已采纳
错误:任务':app:transformClassesWithJarMergingForDebug'.执行失败
buildscript { jcenter() classpath 'com.neenbedankt.gradle.plugins:an
浏览 5修改于2017-01-30得票数 3
我正在尝试做一个示例Rxjava-Retrofit应用程序。我有一个从获取用户输入位置的天气信息的API。public interface ApiInterface { Observable<WeatherData> getWeather(@Query("q") String place);用户必须在编辑文本中输入地名，根据输入的地名，我将调用API。下面是我的全部代码
BehaviorSubject<S
浏览 1提问于2017-08-10得票数 0
总的来说，我对Rx和反应性编程还是比较陌生的。
可观测= Observable.concat( helper.loadFromDevice(params)，helper.loadFromServer(params)) .takeFirst(pastPaper -> pastPaper != null)；observable.subscribe(.)
如果
浏览 8提问于2016-06-18得票数 0
回答已采纳
下面是测试代码 s.onNext(Integer.valueOf(1)); });
s.onNext(Integer.valueOf(2)); });
F
浏览 0修改于2016-12-10得票数 0
[] b = generateFileForB(input); doSomethingWithZip(zip);
} 我如何使用rx-java
浏览 16提问于2020-03-20得票数 0
如果是这样，这是rx-java类层次结构的限制吗？或者，有没有办法解决这个问题，并序列化Notification？
浏览 2提问于2014-04-24得票数 4
我使用了swiperefreshlayout android.support.v4.widget.SwipeRefreshLayout，并使用rxjava在每次滑动发生时向服务器查询。我的代码如下所示，我必须在OnRefreshListener中创建重复的observable和subscriber才能调用它们，由于代码重复，这看起来相当糟糕。如果我使用原始的(在外部声明)，则永远不会返回订阅者(不会触发onNext、onError、onCompleted )。在这种情况下，RxJava遗漏了什么？
Subscriber<ListVerifyResponseWrapper> subs
浏览 0提问于2015-09-18得票数 1
我想在调用我的rx翻新服务之前检查手机是否连接到了互联网。如果没有连接，我想返回一个包含错误的假响应。private Observable<Response> checkNetwork(Observable<Response> retrofitService) { @Override
浏览 0提问于2015-02-25得票数 9
vert.x + rx-java的最佳实践是什么？对不起..。有很多问题，我想我可以缩小到:在Vert.x和Rx-Java中实现Cash for the Service calls的最佳实践是什么？
整个示例都是
浏览 17修改于2017-08-19得票数 0
在java方法中。但在这种方法中，我得到了不同的结果：public Observable<Menu> makeMenu(Menu menu, NumberSettingChanges.MenuChanges changes) { return Observable.from(changes.added.entrySet())
.mergeWith(Observable.from(changes.edited.entrySet())
浏览 0修改于2017-05-23得票数 1
当我试图访问Rx-Java可观测间隔内的视图时，问题就开始了，如下所示：
var interval = Observable.interval(10, TimeUnit.SECONDS, Schedulers.io
浏览 0提问于2018-02-05得票数 1
回答已采纳
我正在学习使用Vert.x的Rx-Java2 2，我想用一些并行任务链接一个成功的配置检索。 public void start(Future<Void> startFuture) throws Exception { configSingle.subscribe(onSuccess -> {
Syst
浏览 0修改于2018-04-03得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号