File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -609,12 +609,11 @@ function ReadableStreamFrom (iterable) {
609609 let iterator
610610 return new ReadableStream (
611611 {
612- async start ( ) {
612+ start ( ) {
613613 iterator = iterable [ Symbol . asyncIterator ] ( )
614614 } ,
615615 pull ( controller ) {
616- async function pull ( ) {
617- const { done, value } = await iterator . next ( )
616+ return iterator . next ( ) . then ( ( { done, value } ) => {
618617 if ( done ) {
619618 queueMicrotask ( ( ) => {
620619 controller . close ( )
@@ -625,15 +624,13 @@ function ReadableStreamFrom (iterable) {
625624 if ( buf . byteLength ) {
626625 controller . enqueue ( new Uint8Array ( buf ) )
627626 } else {
628- return await pull ( )
627+ return this . pull ( controller )
629628 }
630629 }
631- }
632-
633- return pull ( )
630+ } )
634631 } ,
635- async cancel ( ) {
636- await iterator . return ( )
632+ cancel ( ) {
633+ return iterator . return ( )
637634 } ,
638635 type : 'bytes'
639636 }
Original file line number Diff line number Diff line change 11'use strict'
22
3- const { test } = require ( 'node:test' )
43const { deepStrictEqual } = require ( 'node:assert' )
4+ const { test } = require ( 'node:test' )
55const { Response } = require ( '../..' )
66
77// https://github.com/nodejs/node/issues/56474
You can’t perform that action at this time.
0 commit comments