RxJava 可观察问题

Question

在android 6.0.1 Samsung s6 edge+上测试

当设备屏幕脱机并从调试中拔出时，可观察对象只是停止发射项目。如果设备打开，则开始发射对象。 另一个问题是，在停止接收物品之前，我会随机收到 2/3 的重复调用，按顺序排列相同的物品

Observable.interval(4000,
            30000, TimeUnit.MILLISECONDS)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .doOnError(ErrorResponse.handleError()).subscribe(new Action1() {
                        @Override
                        public void call(Object o) {
                            statusSender.doNetworkCallAndGetStringResult();
                        }
                    });

__________________________________编辑__________________________________

做另一篇文章以提供更多详细信息。我不能给你完整的日志，但我会尝试更好地解释我所做的工作以确保问题是可观察到的。

关注

https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java

我用 Rxjava2 尝试了一个不同的实现

isposables.add(statusSender.getObservable(certificate)
                    .subscribeOn(io.reactivex.schedulers.Schedulers.io())
                    .observeOn(io.reactivex.android.schedulers.AndroidSchedulers.mainThread())
                    .subscribeWith(getObserver()))

getObservable 方法

return io.reactivex.Observable.interval(INITIAL_DELAY,Utilities.getInstance().getHeartbeatFrequency(),TimeUnit.MILLISECONDS);

getObserver 方法是 asExample，不同之处在于我在 onNext 内部进行网络调用

private DisposableObserver<Long> getObserver() {
    return new DisposableObserver<Long>() {

        @Override
        public void onNext(Long value) {
            Log.d(TAG, " onNext : value : " + value);
            statusSender.doNetworkCallAndGetStringResult();
        }

        @Override
        public void onError(Throwable e) {
            Log.d(TAG, " onError : " + e.getMessage());
        }

        @Override
        public void onComplete() {
            Log.d(TAG, " onComplete");
        }
    };
}

正在发生的事情的日志

Answer 1

当设备屏幕脱机并从调试中拔出时，可观察对象只是停止发射项目。

这是 Android 上的预期行为：设备将暂停您的活动并切换到低功耗模式以节省电池电量。如果你需要在后台做一些事情，你需要创建一个服务，通过 Android 特定的计时器请求唤醒，并在你的清单中请求保持设备开启的特殊权限（我想，已经有一段时间了） .