Mono.subscribe(消费者、errorConsumer、completeConsumer、subscriptionConsumer)不调用消费者和completeConsumer？

Question

作为主题，Mono.subscribe的第四个变体似乎不会调用成功消费者和完全消费者。它只调用订阅使用者。

下面的代码失败

    CountDownLatch latch = new CountDownLatch(3);
    Mono.just(1).subscribe(i -> latch.countDown(), throwable -> {}, latch::countDown, s -> latch.countDown());
    boolean success = latch.await(1, TimeUnit.SECONDS);
    Assert.assertEquals(true, success);

Answer 1

这是因为带有Consumer<Subscription>的subscribe版本是用来驱动初始request的。如果你不在消费者的订阅上调用request(n)，就不会发出数据，Mono也不会完成...

它的工作方式与预期一致：

CountDownLatch latch = new CountDownLatch(3);
Mono.just(1).subscribe(
            i -> latch.countDown(),
            throwable -> {},
            latch::countDown,
            s -> {
                s.request(Long.MAX_VALUE);
                latch.countDown();
            });
boolean success = latch.await(1, TimeUnit.SECONDS);
Assert.assertEquals(true, success);