Register global onErrorDropped hook with reactor that bubbles runtime

exceptions
pravasna · Feb 14, 2022 · 9f8ff13 · 9f8ff13
1 parent 61ea32f
commit 9f8ff13
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/ratpack-reactor/src/main/java/ratpack/reactor/ReactorRatpack.java b/ratpack-reactor/src/main/java/ratpack/reactor/ReactorRatpack.java
@@ -88,6 +88,9 @@ private ReactorRatpack() {
    * }</pre>
    */
   public static void initialize() {
+    // This is required after upgrading reactor 3.3.7 -> 3.4.14
+    // Due to https://github.com/reactor/reactor-core/issues/1431
+    Hooks.onErrorDropped(reactor.core.Exceptions::bubble);
     Hooks.onLastOperator(ErrorForwarding::decorate);
   }