From e22fc4768e4826799bd5ba46ef066f032b770aa1 Mon Sep 17 00:00:00 2001
From: Violeta Georgieva <violeta.georgieva@broadcom.com>
Date: Thu, 16 May 2024 15:16:22 +0300
Subject: [PATCH] There should be no exception indicating problems with
 ByteBuf#release

---
 .../reactor/netty/http/HttpCompressionClientServerTests.java   | 3 +++
 1 file changed, 3 insertions(+)

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
index 2d9620f925..73d43d89d1 100644
--- 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) {