标签：rx-java
-
RxJava:使用基于Single的累加器进行的扫描，该扫描器处理中间的Single - java
我正在写一个基于Rx的单向UI流，其中每个状态的减少都是一个Single。通常，此类流程是使用scan完成的(它们需要先前的状态)，但是当涉及到Single时，会有些棘手。我设法使它像这样工作: val events = Observable.just("event1", "event2", "event3& […]
-
RxJava-我什么时候应该取消订阅？ - java
我想确保使用RxJava时不会造成任何内存泄漏。请让我知道这些是否是处理每种情况的正确方法。 案例1 如果我在同一范围内创建Observable和Subscription，GC会照顾好它们的处置吗？我必须在这里致电unsubscribe()吗？ public static void createObservableAndSubscribe() { Obser […]
-
RxJava-为什么执行程序只使用一个线程 - java
我创建了一个固定的线程池来处理每300毫秒发出的事件，并假定该过程需要1000毫秒。假设多线程可以工作，但是只有一个线程被重用。 如果我将sleepTime设置为小于300ms，则处理线程会更改，但这没有用。 问题：如何使其并发？为什么程序重用线程？ 先感谢您 public static void main(String[] args) throws Int […]
-
当回复有时是一个对象有时是一个数组时，如何在使用改造时解析JSON回复？ - java
我正在使用Retrofit来获取JSON答复。 这是我实施的一部分- @GET("/api/report/list") Observable<Bills> listBill(@Query("employee_id") String employeeID); 而条例草案类是- public static cl […]