reactor/reactor-pool

Suppress CommonPoolTest#pendingLimitAsync(Function) onErrorDropped logging

simonbasle opened this issue · 0 comments

The test logs

15-Mar-2021 16:03:19 | CommonPoolTest > pendingLimitAsync(Function) [2]LRU & LIFO STANDARD_OUT
-- | --
15-Mar-2021 16:03:19 | Mar 15 2021 16:03:19.256 [boundedElastic-3] ERROR r.c.p.Operators [Loggers.java:314] - Operator called default onErrorDropped
15-Mar-2021 16:03:19 | reactor.core.Exceptions$ErrorCallbackNotImplemented: reactor.pool.PoolAcquirePendingLimitException: Pending acquire queue has reached its maximum size of 1

This is misleading as the error is captured and evaluated above in doOnError.
We can simply rewrite .subscribe() to .subscribe(v -> {}, e -> {}) for that test.