rx-java

5热度

2回答

如何使用Java 9 Flow Interfaces /将它们包含在Java 9中有什么意义？

首先，我必须说，我对反应式编程没有多少经验。由于JDK 9（Flow and its nested interfaces）中只有几个接口，因此JDK 9显然不包含像RxJava这样的反应式库。在Javadoc中，有一些用于实现Publisher,Subscription和Subscriber的示例。但这些似乎是相当低级的，没有任何反应式操作员或处理背压。那么将这些接口包含到JDK中有什么意义

0热度

3回答

哪个库我应该使用RxAndroid和RxJava

我想使用RxAndroid和RxJava，但我有点困惑哪些下面提到的库我应该使用？在一些教程它们使用例如以下类其可在 compile 'io.reactivex:rxandroid:1.2.1' compile 'io.reactivex:rxjava:1.1.9' .subscribe(new Subscriber<String>) 和一些教程哎使用例如它们使用下列类，其是可以在以下

0热度

2回答

如何根据一组值更新数据模型

该方案是基于整数值的Set更新列表中的数据模型。例如有一个ArrayList： Student { name: "abc", id: 1, hasPassed: false }... 现在我有一个整数集，基本上在其内部具有学生ID {1，2，...}通过学生表示学生证。我得到Student arrayList onNext我的observer方法。如何根

0热度

1回答

RxJava。加入来自两个Observable/Flowable流的所有项目

我正在加载一些项目以在单个网页上显示。与此同时，我正在加载物品的价格。简化它看起来像这样： Observable<Integer> ids = itemIdsToShow(); // COLD Observable Observable<Item> items = ids.flatMap(id -> loadingItem(id)); Observable<Price> prices = id

0热度

1回答

节流在RxJava

节流规则：如果在最近的100毫秒发出没有其他项目，下一个项目将被交付立即订户如果没有，缓冲传入的项目，直到1000毫秒超时或缓冲区大小达到500，然后提供缓冲项目清单给用户 RxJava可以实现这个吗？

0热度

1回答

Vertex HttpCllentRequest重定向

我们如何处理vertex HttpClientRequest中的重定向（302响应代码）。是否有可能启用vertx本身来处理重定向，或者我们必须明确处理。请解释如何做到这一点，以防它需要明确地完成。

0热度

1回答

RxJava 2 - 如何链接异步电话

我刚刚开始学习RxJava，所以如果我要求一个新手问题，请不要将它钉死在十字架上，但我已经花了好几天的时间来尝试解决这个问题，但没有取得任何成功。我已经阅读了几乎所有我能找到的文档，并沿着大多数关于http://reactivex.io/tutorials.html的教程进行了跟踪。我搜索了StackOverflow和互联网的其他高低，但显然我似乎是这个星球上唯一有这个问题的人。这很奇怪，因为它基

0热度

1回答

如何进行两次翻新调用并合并结果？

我一直在浏览StackOverflow和其他Android相关的网站，试图抓住这一点，但我仍在挣扎。我使用改造如下做出的API调用： public interface TheMovieDbApi { @GET("genre/{type}/list") Observable<GenresReply<Genre>> getGenreList(@Path("type") String type)

0热度

1回答

在SplashActivity中处理多个TCP和HTTP响应

我应该在SplashActivity中组织2个HTTP（Retrofit + Rx）和2个TCP（KryoNet）请求。当我从所有请求得到响应时，我应该启动MainActivity。如何组合请求，处理响应，然后开始MainActivity？亲爱的开发者，请帮助我。我目前正与琥珀金协议（https://github.com/kyuupichan/electrumx/blob/master/docs

0热度

1回答

代码为301和200

两次打电话GET方法我有一段代码，它使用RxJava zip()操作同时执行两个独立的呼叫我的REST API： @Override public void onItemSelected(AdapterView<?> parent, View view, int position, long id) { Observable<List<Player>> obs_pl