java - Reactivestreams 订阅者不适用于 Spring Reactor Mono。为什么？

Question

我有一个 reactor.core.publisher.Mono 变量并想订阅 org.reactivestreams.Subscriber，尽管它似乎不起作用。我无法得到为什么从未调用过 onNext 方法？我看到 onSubscribe 方法调用很好。我可能弄错了，但是作为 Mono 实现 Publisher，订阅者应该可以工作。对？

@Test
    public void subscriberTest() {
        Mono<String> m = Mono.just("Hello!");
        Subscriber<String> s = new Subscriber<String>() {
            @Override
            public void onSubscribe(Subscription s) {
                System.out.println("Subscription "+s);
            }
            @Override
            public void onNext(String t) {
                System.out.println("onNext "+t);
            }
            @Override
            public void onError(Throwable t) {
                System.out.println("Throwable "+t);
            }
            @Override
            public void onComplete() {
                System.out.println("onComplete");
            }
        };
        m.subscribe(s);

        Mono<String> m1 = Mono.just("Bye!");
        m1.subscribe(System.out::println);
    }

尽管带有方法引用的变量 m1 订阅工作正常。这里控制台输出：

Subscription reactor.core.publisher.StrictSubscriber@4b168fa9
Bye!

在这里我期待看到你好！短语也。

标签： javaspringproject-reactorreactive-streams

Answer 1

https://www.reactive-streams.org/reactive-streams-1.0.0-javadoc/org/reactivestreams/Subscriber.html#onSubscribe-org.reactivestreams.Subscription-这里声明No data will start flowing until Subscription.request(long) is invoked.