fixes deadlock on multiconsumer clear/poll in UnboundedProcessor (#990)

Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
rsocket · Feb 27, 2021 · 61652c3 · 61652c3
1 parent 645c1f6
commit 61652c3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rsocket-core/src/test/java/io/rsocket/internal/UnboundedProcessorTest.java b/rsocket-core/src/test/java/io/rsocket/internal/UnboundedProcessorTest.java
@@ -26,6 +26,7 @@
 import io.rsocket.buffer.LeaksTrackingByteBufAllocator;
 import io.rsocket.internal.subscriber.AssertSubscriber;
 import java.time.Duration;
+import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Timeout;
@@ -45,6 +46,7 @@ public static void setup() {
     Hooks.onErrorDropped(__ -> {});
   }
 
+  @AfterAll
   public static void teardown() {
     Hooks.resetOnErrorDropped();
   }