diff --git a/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java b/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java index c8811b9b3..9b23793d5 100644 --- a/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java +++ b/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java @@ -197,7 +197,7 @@ public void sendErrorAndClose(RSocketErrorException rSocketErrorException) { savableFramesSender.tryEmitFinal( ErrorFrameCodec.encode(activeConnection.alloc(), 0, rSocketErrorException)); - + activeConnection.sendErrorAndClose(rSocketErrorException); activeConnection .onClose() .subscribe(