Consistently throw IOException from ReactorNettyClientResponse

Aligned with ReactorNettyClientRequest.

See gh-32952

spring-web/src/main/java/org/springframework/http/client/ReactorNettyClientRequest.java

@@ -42,6 +42,7 @@
  * Created via the {@link ReactorNettyClientRequestFactory}.
  *
  * @author Arjen Poutsma
+ * @author Juergen Hoeller
  * @since 6.1
  */
 final class ReactorNettyClientRequest extends AbstractStreamingClientHttpRequest {
@@ -101,18 +102,8 @@ protected ClientHttpResponse executeInternal(HttpHeaders headers, @Nullable Body
 				return result;
 			}
 		}
-		catch (RuntimeException ex) {  // Exceptions.ReactiveException is package private
-			Throwable cause = ex.getCause();
-
-			if (cause instanceof UncheckedIOException uioEx) {
-				throw uioEx.getCause();
-			}
-			else if (cause instanceof IOException ioEx) {
-				throw ioEx;
-			}
-			else {
-				throw new IOException(ex.getMessage(), cause);
-			}
+		catch (RuntimeException ex) {
+			throw convertException(ex);
 		}
 	}
 
@@ -136,6 +127,21 @@ private Publisher<Void> send(HttpHeaders headers, @Nullable Body body,
 		}
 	}
 
+	static IOException convertException(RuntimeException ex) {
+		// Exceptions.ReactiveException is package private
+		Throwable cause = ex.getCause();
+
+		if (cause instanceof UncheckedIOException uioEx) {
+			return uioEx.getCause();
+		}
+		else if (cause instanceof IOException ioEx) {
+			return ioEx;
+		}
+		else {
+			return new IOException(ex.getMessage(), cause);
+		}
+	}
+
 
 	private static final class ByteBufMapper implements OutputStreamPublisher.ByteMapper<ByteBuf> {
 

spring-web/src/main/java/org/springframework/http/client/ReactorNettyClientResponse.java

@@ -33,6 +33,7 @@
  * {@link ClientHttpResponse} implementation for the Reactor-Netty HTTP client.
  *
  * @author Arjen Poutsma
+ * @author Juergen Hoeller
  * @since 6.1
  */
 final class ReactorNettyClientResponse implements ClientHttpResponse {
@@ -79,8 +80,13 @@ public InputStream getBody() throws IOException {
 			return body;
 		}
 
-		body = this.connection.inbound().receive()
-				.aggregate().asInputStream().block(this.readTimeout);
+		try {
+			body = this.connection.inbound().receive().aggregate().asInputStream().block(this.readTimeout);
+		}
+		catch (RuntimeException ex) {
+			throw ReactorNettyClientRequest.convertException(ex);
+		}
+
 		if (body == null) {
 			throw new IOException("Could not receive body");
 		}