Skip to content

Commit 61652c3

Browse files
committed
fixes deadlock on multiconsumer clear/poll in UnboundedProcessor (#990)
Signed-off-by: Oleh Dokuka <[email protected]>
1 parent 645c1f6 commit 61652c3

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

rsocket-core/src/test/java/io/rsocket/internal/UnboundedProcessorTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import io.rsocket.buffer.LeaksTrackingByteBufAllocator;
2727
import io.rsocket.internal.subscriber.AssertSubscriber;
2828
import java.time.Duration;
29+
import org.junit.jupiter.api.AfterAll;
2930
import org.junit.jupiter.api.BeforeAll;
3031
import org.junit.jupiter.api.RepeatedTest;
3132
import org.junit.jupiter.api.Timeout;
@@ -45,6 +46,7 @@ public static void setup() {
4546
Hooks.onErrorDropped(__ -> {});
4647
}
4748

49+
@AfterAll
4850
public static void teardown() {
4951
Hooks.resetOnErrorDropped();
5052
}

0 commit comments

Comments
 (0)