fix FlowController.acquire error (#147)

daleiz · web-flow · commit 923df9b3b968 · 2022-10-14T17:48:29.000+08:00
diff --git a/client/src/main/kotlin/io/hstream/impl/BufferedProducerKtImpl.kt b/client/src/main/kotlin/io/hstream/impl/BufferedProducerKtImpl.kt
@@ -184,7 +184,14 @@ class BufferedProducerKtImpl(
                     leftBytes -= bytes
                     null
                 } else {
-                    val waitBytes = bytes - leftBytes
+                    val waitBytes =
+                        if (leftBytes == 0) {
+                            bytes
+                        } else {
+                            val waitBytes = bytes - leftBytes
+                            leftBytes = 0
+                            waitBytes
+                        }
                     val bytesWaiter = BytesWaiter(waitBytes)
                     waitingList.addLast(bytesWaiter)
                     bytesWaiter
