Update request body write to retain inputstream buffer

microsoft · Aug 19, 2024 · 418176a · 418176a
1 parent 6291fa2
commit 418176a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/components/http/okHttp/gradle/dependencies.gradle b/components/http/okHttp/gradle/dependencies.gradle
@@ -12,6 +12,7 @@ dependencies {
  implementation 'io.opentelemetry:opentelemetry-api:1.41.0'
  implementation 'io.opentelemetry:opentelemetry-context:1.41.0'
  implementation 'jakarta.annotation:jakarta.annotation-api:2.1.1'
+ implementation 'com.google.guava:guava:33.3.0-jre'
  api 'com.squareup.okhttp3:okhttp:4.12.0'
 
  api project(':components:abstractions')

diff --git a/components/http/okHttp/src/main/java/com/microsoft/kiota/http/OkHttpRequestAdapter.java b/components/http/okHttp/src/main/java/com/microsoft/kiota/http/OkHttpRequestAdapter.java
@@ -2,6 +2,7 @@
 
 import static com.microsoft.kiota.http.TelemetrySemanticConventions.*;
 
+import com.google.guava.ByteStreams;
 import com.microsoft.kiota.*;
 import com.microsoft.kiota.authentication.AuthenticationProvider;
 import com.microsoft.kiota.http.middleware.ParametersNameDecodingHandler;
@@ -28,7 +29,6 @@
 import okhttp3.*;
 
 import okio.BufferedSink;
-import okio.Okio;
 
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
@@ -922,7 +922,7 @@ public long contentLength() throws IOException {
 
  @Override
  public void writeTo(@Nonnull BufferedSink sink) throws IOException {
- sink.writeAll(Okio.source(requestInfo.content));
+ sink.write(ByteStreams.toByteArray(requestInfo.content));
  }
  };