rxjava2-discussion

rxjava2-discussion copied to clipboard

如何真正地取消网络请求？

1

比如，RxJava 1.x版本CompositeSubscription类提供的unsubscribe()方法；或者，再比如，RxJava 2.x版本CompositeDisposable类提供的clear()方法； 经过网络抓包测试，它们只是取消了RxJava的订阅，并不能取消网络请求。 那么如何才能真正地取消网络请求？

PiPiCaptain

delay的疑惑

7

``` Observable.just("Alex").delay(1000, TimeUnit.MILLISECONDS) .doOnSubscribe(new LiteConsumer() { @Override public void onNext(Disposable result) { LogTrack.e("只有 这里 会执行"); } }) .doOnTerminate(new Action() { @Override public void run() throws Exception { LogTrack.e(" -- ");...

Alex-Cin

RxJava能嵌套吗？

2

RxJava能嵌套吗？就是在onComplete()或者accept()里在重新创建rxjava的observable 和subscribe，这样会不会有问题，如果可以会不会有内存泄漏的风险，或者其他性能及安全上的问题

luoqqsh

如何实现多个接口数据请求完成之后在做展示处理？

8

比如有一个页面，需要从3个不同的接口获取3个不同的数据进行计算后才能显示在屏幕上，那就意味着我的先保证3个接口都能正常获取到数据，不知道rxjava能否实现，怎么实现，提供下思路谢谢！可以给我个参考代码（伪代码）

luoqqsh

关于显示loading的问题

2

我现在的需求网络请求如果请求结果在200毫秒内就不显示loading界面，如果请求超过200毫秒就显示loading界面，然后返回结果时候显示正常界面，用rx应该怎么实现比较好呢？ 我现在的实现方式是把一个空数据和请求mergewith 但是我觉得这样非常不rx，想问问大家觉得怎么搞？ ```Java Observable loading = Observable.just(emptyList).delay(200, TimeUnit.MILLISECONDS); mAppMainModel.getMainData() .mergeWith(loading) .filter(valueBlock -> { return (valueBlock.nav != null && valueBlock.nav.size() != 0) || mNavItems == null; }) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer()...

cctanfujun