language-servers/deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-10-01 06:31:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fix(fetch): a consumed body with a non-stream source should result in a disturbed stream (#11217)

Browse source
This commit is contained in:
Andreu Botella 2021-07-02 11:34:12 +02:00 • committed by GitHub
parent 513f921219
commit 4bc8fe71db
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

6
extensions/fetch/22_body.js
View file

@ -41,14 +41,16 @@
get stream() { get stream() {
if (!(this.streamOrStatic instanceof ReadableStream)) { if (!(this.streamOrStatic instanceof ReadableStream)) {
const { body, consumed } = this.streamOrStatic; const { body, consumed } = this.streamOrStatic;
if (consumed) {
this.streamOrStatic = new ReadableStream();
this.streamOrStatic.getReader();
} else {
this.streamOrStatic = new ReadableStream({ this.streamOrStatic = new ReadableStream({
start(controller) { start(controller) {
controller.enqueue(body); controller.enqueue(body);
controller.close(); controller.close();
}, },
}); });
if (consumed) {
this.streamOrStatic.cancel();
} }
} }
return this.streamOrStatic; return this.streamOrStatic;