chore: tweak backpressure handling

tardis-dev · Dec 16, 2021 · 96523af · 96523af
1 parent 2f81942
commit 96523af
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/minion.ts b/src/minion.ts
@@ -352,7 +352,7 @@ class Minion {
 
   private async _send(ws: WebSocket, getMessage: () => string | undefined) {
     let retries = 0
-    while (ws.getBufferedAmount() > 0) {
+    while (ws.getBufferedAmount() > this.MAX_BACKPRESSURE / 2) {
       await wait(10)
       retries += 1