使用reactive 4.2.0我可以扫描订阅内部的计数吗

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.functions.BiFunction;

public class ReactiveExample {
    public static void main(String[] args) {
        // 创建一个数据流
        Observable<Integer> numbers = Observable.just(1, 2, 3, 4, 5);

        // 使用scan操作符进行计数
        Observable<Integer> count = numbers.scan(0, new BiFunction<Integer, Integer, Integer>() {
            @Override
            public Integer apply(Integer accumulator, Integer value) throws Exception {
                return accumulator + 1;
            }
        });

        // 订阅计数后的数据流
        count.subscribe(new Consumer<Integer>() {
            @Override
            public void accept(Integer value) throws Exception {
                System.out.println("Count: " + value);
            }
        });
    }
}