rx-java

2热度

3回答

帮助撰写多个网络电话并在Rxjava中累积结果。（我正在使用的Android应用程序。） State -- List<City> cityList; City - cityId; RestCall 1 Observable<State> stateRequest = restService.getStates(); RestCall 2 Observable<CityDeta

16热度

1回答

如何在RxJava中的自定义Observable中获得观察者的取消订阅操作的通知

我试图将一些基于侦听器模式的API包装到Observable中。我的代码大致如下所示。 def myObservable = Observable.create({ aSubscriber -> val listener = {event -> aSubscriber.onNext(event); } existingEventSource.add

10热度

2回答

如何在RxJava中使用TestScheduler

我应该如何使用RxJava的TestScheduler？我来自.NET背景，但RxJava中的TestScheduler似乎与.NET rx中的测试调度程序的工作方式不同。这里是我想测试 Observable<Long> tick = Observable.interval(1, TimeUnit.SECONDS); contactsRepository.find(index) .b

0热度

3回答

Observable的占位符？

可以说我有两个Observable A和B. 当服务连接到我的程序时，A发出true。如果服务启动，则B发出true，否则为false。我想使用combineLatest结合A和B，然后采取适当的行动。问题是B在我连接到服务之前不可用。所以我的问题是，如果我可以有B的Observable-wrapper和占位符，直到B可用？然后，当B可用时，包装应该发出来自B的值。

15热度

1回答

RxJava链观察和错误处理（自定义异常传播）

我有5 Observable s它与flatMap链接。如果前四个Observable s产生一个Exception我想传播一个不同类型的Exception到第五个。它是如何实现的？谢谢。 P.S. 我想出这个尚未检验的解决方案： flatMap( // onNext new Func1<BoolResponse, Observable<?>>() { @O

53热度

2回答

RxJava并行获取观察值

我需要一些帮助来实现RxJava中的并行异步调用。我选择了一个简单的用例，其中FIRST调用获取（而不是搜索）要显示的产品列表（Tile）。随后调用出去取（A）审查和（B）产品图片多次尝试我到这个地方之后。 1 Observable<Tile> searchTile = searchServiceClient.getSearchResults(searchTerm); 2 List<Tile>

1热度

1回答

refCount：在连接“n”观察者之后调用底层ConnectObservable.connect（）

0热度

1回答

RX Java多订阅

想象一下，您需要加载一些数据并将其保存到您的碎片中。我想使用RX Java。你如何处理一个片段上的多个订阅？ AndroidObservable.bindFragment完成作业。但是当我需要更多订阅时，我该如何使用它？ public class MyFragment extends SomeFragment implements Observer<List<Item>> { privat

0热度

1回答

如何观察碎片初始化RxJava/RxAndroid？

我有两个片段，每个都有发布主题，在onResume（）初始化时调用onNext（true）。我想结合这两个主题，并在他们都返回true时调用第三类中的某些方法。我需要使用Observable吗？我无法找到合适的操作，因为这些是主题，所以压缩不起作用。我如何结合这些？

1热度

2回答

为什么这个observable只发出一个值

我有以下代码根据@ a.bertucci在这里提供的示例Emit objects for drawing in the UI in a regular interval using RxJava on Android，其中我使用Timer对一个Observable进行压缩。当我通过调用processDelayedItems（）来触发订阅时，压缩的Observable中的代码[A]只执行一次，一个项