Clean up Guava usage (CountingOutputStream) (#43942)

Summary: Pull Request resolved: #43942 Move the counting inline to remove its only usage Changelog: [Internal] Reviewed By: zeyap Differential Revision: D55802174
facebook · Apr 23, 2024 · 3cc9b5f · 3cc9b5f
1 parent b2c3ee5
commit 3cc9b5f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 60 deletions.
diff --git a/...ive/ReactAndroid/src/main/java/com/facebook/react/modules/network/CountingOutputStream.kt b/...ive/ReactAndroid/src/main/java/com/facebook/react/modules/network/CountingOutputStream.kt
diff --git a/...tive/ReactAndroid/src/main/java/com/facebook/react/modules/network/ProgressRequestBody.kt b/...tive/ReactAndroid/src/main/java/com/facebook/react/modules/network/ProgressRequestBody.kt
@@ -7,6 +7,7 @@
 
 package com.facebook.react.modules.network
 
+import java.io.FilterOutputStream
 import java.io.IOException
 import okhttp3.MediaType
 import okhttp3.RequestBody
@@ -48,16 +49,20 @@ internal class ProgressRequestBody(
 
   private fun outputStreamSink(sink: BufferedSink): Sink =
       Okio.sink(
-          object : CountingOutputStream(sink.outputStream()) {
+          object : FilterOutputStream(sink.outputStream()) {
+            private var count = 0L
+
             @Throws(IOException::class)
             override fun write(b: ByteArray, off: Int, len: Int) {
               super.write(b, off, len)
+              count += len.toLong()
               sendProgressUpdate()
             }
 
             @Throws(IOException::class)
             override fun write(b: Int) {
               super.write(b)
+              count++
               sendProgressUpdate()
             }