RxJava-延迟和延迟订阅之间的区别是什么？

Question

我试图理解延迟和延迟订阅操作符之间的区别。

本文件描述了延迟操作员：

延迟操作符通过在发出每个源可观察项之前暂停特定的时间增量（您指定）来修改其源可观察项。这会将可观测项发出的整个项目序列在时间上向前移动指定的增量

delaySubscription是这样描述的：

还有一个操作符，您可以使用它延迟对源可观察对象的订阅：delaySubscription。

然而，当我测试这两个操作员的行为时，我觉得他们的工作方式是一样的。

这是我观察到的：

Observable observable = Observable.just(5, 3, 4, 2);

这里我使用延迟运算符：

observable = observable.delay(3, TimeUnit.SECONDS);

这是我的观察者，当它的一个方法被调用时，它会记录日志

Observer observer = new Observer() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d("RxJavaTag", "onSubscribe");
            }

            @Override
            public void onNext(Object o) {
                Log.d("RxJavaTag", "onNext: " + o);
            }

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

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

这里，观察者订阅了Observable：

observable.subscribe(observer);

因此，当我使用延迟操作符时，我得到以下日志：

03-25 17:45:34.156 onSubscribe
03-25 17:45:37.160 onNext: 5
03-25 17:45:37.160 onNext: 3
03-25 17:45:37.160 onNext: 4
03-25 17:45:37.160 onNext: 2
03-25 17:45:37.160 onComplete

以及使用delaySubscription运算符时的以下日志：

03-25 17:49:22.540 onSubscribe
03-25 17:49:25.544 onNext: 5
03-25 17:49:25.544 onNext: 3
03-25 17:49:25.544 onNext: 4
03-25 17:49:25.544 onNext: 2
03-25 17:49:25.544 onComplete

正如您在日志中看到的，它们的工作方式相同。我无法理解它们之间的区别。我试图用ConnectableWatable测试它——相同的行为。

根据我的理解，正如其名称所示，不应以这种方式延迟订阅运营商的工作：

[SOME DELAY - FOR EXAMPLE 3 SECONDS]
03-25 17:49:25.540 onSubscribe
03-25 17:49:25.544 onNext: 5
03-25 17:49:25.544 onNext: 3
03-25 17:49:25.544 onNext: 4
03-25 17:49:25.544 onNext: 2
03-25 17:49:25.544 onComplete

也许我做错了什么，但我无法理解其中的区别。你能解释一下延迟和延迟订阅的区别吗？

Answer 1

当你看到操作符一个接一个的时候，这是非常清楚的（就像你贴的那样）。通常，当订阅延迟时，您会“松开”红色和橙色大理石。与延迟相比，延迟只会给你带来延迟。

Answer 2

延迟订阅仅影响初始订阅。在订阅了下游可观察到的后，它就正常工作了。

延迟对下一个、完成的和错误的事件起作用，将这些事件延迟指定的时间量，但保持它们之间的相对延迟不变。

如果您使用比O更不可预测的源代码，差异会更明显bservable.just

Answer 3

你可以把这想象成一场足球比赛的流，源发出帧[一个热的可见光]。

假设实时流场景...在延迟（3秒）的情况下，一旦您打开频道，您将被订阅，但将在实际发射3秒后收到第一帧，因此您将继续观看游戏延迟3秒。

在delaySubscription（3秒）的情况下，一旦您打开频道，您将等待3秒（错过这3秒内发出的任何帧），然后订阅并开始实时接收其余帧