diff options
| author | Matt Mastracci <matthew@mastracci.com> | 2023-12-01 08:56:10 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-12-01 08:56:10 -0700 |
| commit | e6e708e46c51f3154a81ed99cd35c3d5569930f9 (patch) | |
| tree | 57a0fdd4c0a5911b62b5af02d09d5a2d9de77ed9 /ext/node/polyfills/_http_outgoing.ts | |
| parent | 687ae870d1e4e856b7ceee0a5511138459c68cb1 (diff) | |
refactor: use resourceForReadableStream for fetch (#20217)
Switch `ext/fetch` over to `resourceForReadableStream` to simplify and
unify implementation with `ext/serve`. This allows us to work in Rust
with resources only.
Two additional changes made to `resourceForReadableStream` were
required:
- Add an optional length to `resourceForReadableStream` which translates
to `size_hint`
- Fix a bug where writing to a closed stream that was full would panic
Diffstat (limited to 'ext/node/polyfills/_http_outgoing.ts')
| -rw-r--r-- | ext/node/polyfills/_http_outgoing.ts | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/ext/node/polyfills/_http_outgoing.ts b/ext/node/polyfills/_http_outgoing.ts index 50869ad82..8882ade55 100644 --- a/ext/node/polyfills/_http_outgoing.ts +++ b/ext/node/polyfills/_http_outgoing.ts @@ -4,7 +4,6 @@ // TODO(petamoriken): enable prefer-primordials for node polyfills // deno-lint-ignore-file prefer-primordials -const core = globalThis.__bootstrap.core; import { getDefaultHighWaterMark } from "ext:deno_node/internal/streams/state.mjs"; import assert from "ext:deno_node/internal/assert.mjs"; import EE from "node:events"; @@ -544,7 +543,7 @@ export class OutgoingMessage extends Stream { data = new Uint8Array(data.buffer); } if (data.buffer.byteLength > 0) { - core.writeAll(this._bodyWriteRid, data).then(() => { + this._bodyWriter.write(data).then(() => { callback?.(); this.emit("drain"); }).catch((e) => { |