From 193d489994ea89b1a46c2ce0962e10be4f0be463 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Simon=20Basl=C3=A9?= Date: Thu, 1 Apr 2021 16:38:45 +0200 Subject: [PATCH] Make log quieter in CommonPoolTest#pendingLimitAsync The test would log an `ErrorCallbackNotImplemented` but the error is actually evaluated in a `doOnError`, so we can suppress this output by subscribing with an empty error handler. Fixes #125. --- src/test/java/reactor/pool/CommonPoolTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/reactor/pool/CommonPoolTest.java b/src/test/java/reactor/pool/CommonPoolTest.java index bf8145e6..3962f1f4 100644 --- a/src/test/java/reactor/pool/CommonPoolTest.java +++ b/src/test/java/reactor/pool/CommonPoolTest.java @@ -974,7 +974,7 @@ void pendingLimitAsync(Function, AbstractPool> else otherTerminationCount.incrementAndGet(); }) .doOnError(error::set) - .subscribe() + .subscribe(v -> {}, e -> {}) ); RaceTestUtils.race(runnable, runnable);