diff options
author | 2022-11-20 07:02:53 -0800 | |
---|---|---|
committer | 2022-11-20 07:02:53 -0800 | |
commit | 6965b5c19284153ad1a45fcecf59ef2e897c856e (patch) | |
tree | d1bdba615d91e9f65b529e4271b6f702c0afcc73 /src/bun.js/builtins/js | |
parent | dfa62b660d6bde4dc210158920b4bf397ca8cd45 (diff) | |
download | bun-6965b5c19284153ad1a45fcecf59ef2e897c856e.tar.gz bun-6965b5c19284153ad1a45fcecf59ef2e897c856e.tar.zst bun-6965b5c19284153ad1a45fcecf59ef2e897c856e.zip |
mild clean up
Diffstat (limited to 'src/bun.js/builtins/js')
-rw-r--r-- | src/bun.js/builtins/js/ReadableStreamDefaultReader.js | 13 | ||||
-rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 7 |
2 files changed, 10 insertions, 10 deletions
diff --git a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js index 4671f1458..77da965ed 100644 --- a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js +++ b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js @@ -80,11 +80,14 @@ function readMany() return controller.@pull( controller ).@then( - ({done, value}) => ( - done ? - { done: true, value: [], size: 0 } : - { value: [value], size: 1, done: false } - )); + function({done, value}) { + return ( + done ? + { done: true, value: [], size: 0 } : + { value: [value], size: 1, done: false } + ); + } + ); } const content = queue.content; diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js index c6115a456..e8c9667a0 100644 --- a/src/bun.js/builtins/js/ReadableStreamInternals.js +++ b/src/bun.js/builtins/js/ReadableStreamInternals.js @@ -795,10 +795,6 @@ function readDirectStream(stream, sink, underlyingSource) { @putByIdDirectPrivate(stream, "underlyingSource", @undefined); @putByIdDirectPrivate(stream, "start", @undefined); - - var capturedStream = stream; - var reader; - function close(stream, reason) { if (reason && underlyingSource?.cancel) { try { @@ -819,7 +815,7 @@ function readDirectStream(stream, sink, underlyingSource) { } else { @putByIdDirectPrivate(stream, "state", @streamClosed); } - + stream = @undefined; } } @@ -856,6 +852,7 @@ function readDirectStream(stream, sink, underlyingSource) { return maybePromise.@then(() => {}); } + } @linkTimeConstant; |