Skip to content

Commit 813a78b

Browse files
committed
ensure bubble error does not throw back
Signed-off-by: Oleh Dokuka <[email protected]> Signed-off-by: Oleh Dokuka <[email protected]>
1 parent 2814dd8 commit 813a78b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

rsocket-core/src/main/java/io/rsocket/internal/UnboundedProcessor.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -422,7 +422,10 @@ public int requestFusion(int requestedMode) {
422422

423423
@Override
424424
public void dispose() {
425-
super.dispose();
425+
try {
426+
super.dispose();
427+
} catch (Throwable ignored) {
428+
}
426429
cancel();
427430
}
428431

0 commit comments

Comments
 (0)