Mono.subscribe（consumer、errorConsumer、completeConsumer、subscriptionConsumer）はconsumerおよびcompleteConsumerを呼び出しませんか？

Question

件名として、Mono.subscribeの4番目の変種は、成功した消費者と完全な消費者を呼び出すようではありません。サブスクリプションコンシューマを呼び出すだけです。

次のコードは、あなたが最初のrequestを駆動するためConsumer<Subscription>と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

に失敗しました。あなたは、消費者にサブスクリプションにrequest(n)を呼び出さないと、データが放出されませんとMonoは、完全な...

これは期待どおりに動作しません。SimonBaslé@

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);