当我在FlowableOnSubscribe类中调用onNext时，订阅者的onNext和onComplete函数不会运行

Flowable<Integer> flowable = Flowable.create(new FlowableOnSubscribe<Integer>() {
    @Override
    public void subscribe(FlowableEmitter<Integer> emitter) throws Exception {
        emitter.onNext(1);
        emitter.onComplete();
    }
}, BackpressureStrategy.BUFFER);

flowable.subscribe(new Subscriber<Integer>() {
    @Override
    public void onSubscribe(Subscription s) {
        s.request(Long.MAX_VALUE);
    }

    @Override
    public void onNext(Integer integer) {
        System.out.println("onNext: " + integer);
    }

    @Override
    public void onError(Throwable t) {
        System.out.println("onError: " + t.getMessage());
    }

    @Override
    public void onComplete() {
        System.out.println("onComplete");
    }
});

flowable.subscribe(new Subscriber<Integer>() {
    private Subscription subscription;

    @Override
    public void onSubscribe(Subscription s) {
        subscription = s;
        subscription.request(1); // 请求处理1个数据
    }

    @Override
    public void onNext(Integer integer) {
        System.out.println("onNext: " + integer);
        subscription.request(1); // 请求处理下一个数据
    }

    @Override
    public void onError(Throwable t) {
        System.out.println("onError: " + t.getMessage());
    }

    @Override
    public void onComplete() {
        System.out.println("onComplete");
    }
});