Remove unnecessary coroutine from streams/compression.c++

cloudflare · Jan 22, 2024 · b57341b · b57341b
1 parent fbd170a
commit b57341b
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/workerd/api/streams/compression.c++ b/src/workerd/api/streams/compression.c++
@@ -173,12 +173,11 @@ public:
         kj::throwFatalException(kj::cp(exception));
       }
       KJ_CASE_ONEOF(open, Open) {
-        for (auto &piece : pieces) {
-          if (piece.size() != 0) {
-            co_await write(piece.begin(), piece.size());
-          }
-        }
-        co_return;
+        if (pieces.size() == 0) return kj::READY_NOW;
+        return write(pieces[0].begin(), pieces[0].size())
+            .then([this, pieces = pieces.slice(1)]() mutable {
+          return write(pieces);
+        });
       }
     }
     KJ_UNREACHABLE;