基于时间的事件调用 RxJava 操作符

如何解决基于时间的事件调用 RxJava 操作符

我有以下代码：

Observable
                .just(8,9,10)
                .doOnNext(i -> System.out.println("A: " + i))
                .filter(i -> {
                    return i % 3 > 0;
                })
                .doOnNext(i -> System.out.println("B: " + i))
                .map(i -> {
                    Thread.sleep(3000);
                    return "#" + i * 10;
                })
                .doOnNext(s -> System.out.println("C: " + s))
                .filter(s -> s.length() < 4)
                .subscribe(s -> System.out.println("D: " + s));

输出为：

A: 8
B: 8
C: #80
D: #80
A: 9
A: 10
B: 10
C: #100

输出表明，前 8 个通过所有可观察的运算符，然后是 9，然后是 10。即使在 map 运算符中处理 8 需要时间，9 也不会发送到过滤运算符。为什么会这样？似乎我没有正确理解 RxJava 的工作原理。