Skip to content

Commit 10c127a

Browse files
committed
Merge #2763 into 1.1.6
2 parents 5fc9ab9 + a9fe467 commit 10c127a

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

reactor-netty-core/src/test/java/reactor/netty/NettyOutboundTest.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2017-2021 VMware, Inc. or its affiliates, All Rights Reserved.
2+
* Copyright (c) 2017-2023 VMware, Inc. or its affiliates, All Rights Reserved.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -41,6 +41,7 @@
4141
import io.netty.channel.FileRegion;
4242
import io.netty.channel.embedded.EmbeddedChannel;
4343
import io.netty.handler.codec.MessageToMessageEncoder;
44+
import io.netty.handler.codec.UnsupportedMessageTypeException;
4445
import io.netty.handler.ssl.SslContext;
4546
import io.netty.handler.ssl.SslContextBuilder;
4647
import io.netty.handler.ssl.SslHandler;
@@ -244,6 +245,8 @@ public NettyOutbound withConnection(Consumer<? super Connection> withConnection)
244245
.endsWith("End of File");
245246

246247
assertThat(f.isSuccess()).isFalse();
248+
assertThat(f.cause()).isNotNull()
249+
.isInstanceOf(UnsupportedMessageTypeException.class);
247250
assertThat(channel.finishAndReleaseAll()).isTrue();
248251
}
249252

0 commit comments

Comments
 (0)