Skip to content

Commit 80c9b58

Browse files
mostroverkhovyschimke
authored andcommitted
Release SetupFrame on RSocket version mismatch (#472)
1 parent ec42c83 commit 80c9b58

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

rsocket-core/src/main/java/io/rsocket/RSocketFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -336,6 +336,7 @@ private Mono<? extends Void> processSetupFrame(
336336
ClientServerInputMultiplexer multiplexer, Frame setupFrame) {
337337
int version = Frame.Setup.version(setupFrame);
338338
if (version != SetupFrameFlyweight.CURRENT_VERSION) {
339+
setupFrame.release();
339340
InvalidSetupException error =
340341
new InvalidSetupException(
341342
"Unsupported version " + VersionFlyweight.toString(version));

0 commit comments

Comments
 (0)