Added Hooks.onErrorDropped()

scalecube · Apr 6, 2021 · 68f209f · 68f209f
1 parent 1a0fc9f
commit 68f209f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/services/src/test/java/io/scalecube/services/BaseTest.java b/services/src/test/java/io/scalecube/services/BaseTest.java
@@ -5,11 +5,17 @@
 import org.junit.jupiter.api.TestInfo;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import reactor.core.publisher.Hooks;
 
 public abstract class BaseTest {
 
   protected static final Logger LOGGER = LoggerFactory.getLogger(BaseTest.class);
 
+  static {
+    Hooks.onErrorDropped(
+        throwable -> LOGGER.warn("[onErrorDropped] error: {}", throwable.toString()));
+  }
+
   @BeforeEach
   public final void baseSetUp(TestInfo testInfo) {
     LOGGER.info(