There should be no exception indicating problems with ByteBuf#release

reactor · May 16, 2024 · e22fc47 · e22fc47
1 parent e4badf2
commit e22fc47
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/reactor-netty-http/src/test/java/reactor/netty/http/HttpCompressionClientServerTests.java b/reactor-netty-http/src/test/java/reactor/netty/http/HttpCompressionClientServerTests.java
@@ -565,6 +565,7 @@ private void doTestIssue825_2(BiFunction<ByteBuf, HttpServerResponse, Publisher<
 		int port2 = SocketUtils.findAvailableTcpPort();
 
 		AtomicReference<Throwable> error = new AtomicReference<>();
+		AtomicReference<Throwable> bufferReleasedError = new AtomicReference<>();
 		DisposableServer server1 = null;
 		DisposableServer server2 = null;
 		Sinks.Empty<Void> bufferReleased = Sinks.empty();
@@ -601,6 +602,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 					                        .uri("/")
 					                        .responseContent()
 					                        .retain()
+					                        .doOnError(bufferReleasedError::set)
 					                        .flatMap(b -> serverFn.apply(b, out))
 					                        .doOnError(error::set))
 					          .bindNow();
@@ -626,6 +628,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 
 			assertThat(error.get()).isNotNull()
 			                       .isInstanceOf(RuntimeException.class);
+			assertThat(bufferReleasedError.get()).isNull();
 		}
 		finally {
 			if (server1 != null) {