Do not defer the call to pumpTo with kj::evalNow

cloudflare · May 24, 2023 · de23514 · de23514
1 parent 069a825
commit de23514
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/workerd/api/streams/readable.c++ b/src/workerd/api/streams/readable.c++
@@ -472,11 +472,9 @@ kj::Promise<DeferredProxy<void>> ReadableStream::pumpTo(
     bool end) {
   JSG_REQUIRE(IoContext::hasCurrent(), Error,
       "Unable to consume this ReadableStream outside of a request");
-  return kj::evalNow([&]() -> kj::Promise<DeferredProxy<void>> {
-    JSG_REQUIRE(!isDisturbed(), TypeError, "The ReadableStream has already been read.");
-    JSG_REQUIRE(!isLocked(), TypeError, "The ReadableStream has been locked to a reader.");
-    return getController().pumpTo(js, kj::mv(sink), end);
-  });
+  JSG_REQUIRE(!isDisturbed(), TypeError, "The ReadableStream has already been read.");
+  JSG_REQUIRE(!isLocked(), TypeError, "The ReadableStream has been locked to a reader.");
+  return getController().pumpTo(js, kj::mv(sink), end);
 }
 
 jsg::Ref<ReadableStream> ReadableStream::constructor(