fix: Propagate IOExceptions in OkHttpFluxRequestBody (#47170)

* fix: Propagate IOExceptions in OkHttpFluxRequestBody

* add Checkstyle suppression for ThrowFromClientLoggerCheck

Author: mlichtblau

sdk/core/azure-core-http-okhttp/checkstyle-suppressions.xml

@@ -5,4 +5,5 @@
 <suppressions>
   <suppress files="com.azure.core.http.okhttp.OkHttpAsyncHttpClientBuilder.java" checks="io.clientcore.linting.extensions.checkstyle.checks.ExternalDependencyExposedCheck" />
   <suppress files="com.azure.core.http.okhttp.OkHttpAsyncHttpClientBuilder.java" checks="io.clientcore.linting.extensions.checkstyle.checks.ServiceClientBuilderCheck" />
+  <suppress files="com.azure.core.http.okhttp.implementation.OkHttpFluxRequestBody.java" checks="io.clientcore.linting.extensions.checkstyle.checks.ThrowFromClientLoggerCheck" />
 </suppressions>

sdk/core/azure-core-http-okhttp/src/main/java/com/azure/core/http/okhttp/implementation/OkHttpFluxRequestBody.java

@@ -83,15 +83,23 @@ public void writeTo(BufferedSink bufferedSink) throws IOException {
                 }
             }, 1, 1).then();
 
-            // The blocking happens on OkHttp thread pool.
-            if (callTimeoutMillis > 0) {
-                /*
-                 * Default call timeout (in milliseconds). By default there is no timeout for complete calls, but
-                 * there is for the connection, write, and read actions within a call.
-                 */
-                requestSendMono.block(Duration.ofMillis(callTimeoutMillis));
-            } else {
-                requestSendMono.block();
+            try {
+                // The blocking happens on OkHttp thread pool.
+                if (callTimeoutMillis > 0) {
+                    /*
+                     * Default call timeout (in milliseconds). By default there is no timeout for complete calls, but
+                     * there is for the connection, write, and read actions within a call.
+                     */
+                    requestSendMono.block(Duration.ofMillis(callTimeoutMillis));
+                } else {
+                    requestSendMono.block();
+                }
+            } catch (RuntimeException e) {
+                if (e.getCause() instanceof IOException) {
+                    throw (IOException) e.getCause();
+                } else {
+                    throw e;
+                }
             }
         } else {
             // Prevent OkHttp from potentially re-sending non-repeatable body outside of retry policies.