Skip to content

Commit 83a8f30

Browse files
committed
Fixup the exports in node:stream/web
Fixes: #1711
1 parent fa43e8f commit 83a8f30

File tree

2 files changed

+23
-19
lines changed

2 files changed

+23
-19
lines changed

src/node/stream/web.js

+18-19
Original file line numberDiff line numberDiff line change
@@ -3,25 +3,24 @@
33
// https://opensource.org/licenses/Apache-2.0
44
//
55
/* eslint-disable */
6-
export {
7-
ReadableStream,
8-
ReadableStreamDefaultReader,
9-
ReadableStreamBYOBReader,
10-
ReadableStreamBYOBRequest,
11-
ReadableByteStreamController,
12-
ReadableStreamDefaultController,
13-
TransformStream,
14-
TransformStreamDefaultController,
15-
WritableStream,
16-
WritableStreamDefaultWriter,
17-
WritableStreamDefaultController,
18-
ByteLengthQueuingStrategy,
19-
CountQueuingStrategy,
20-
TextEncoderStream,
21-
TextDecoderStream,
22-
CompressionStream,
23-
DecompressionStream,
24-
}
6+
7+
export const ReadableStream = globalThis.ReadableStream;
8+
export const ReadableStreamDefaultReader = globalThis.ReadableStreamDefaultReader;
9+
export const ReadableStreamBYOBReader = globalThis.ReadableStreamBYOBReader;
10+
export const ReadableStreamBYOBRequest = globalThis.ReadableStreamBYOBRequest;
11+
export const ReadableByteStreamController = globalThis.ReadableByteStreamController;
12+
export const ReadableStreamDefaultController = globalThis.ReadableStreamDefaultController;
13+
export const TransformStream = globalThis.TransformStream;
14+
export const TransformStreamDefaultController = globalThis.TransformStreamDefaultController;
15+
export const WritableStream = globalThis.WritableStream;
16+
export const WritableStreamDefaultWriter = globalThis.WritableStreamDefaultWriter;
17+
export const WritableStreamDefaultController = globalThis.WritableStreamDefaultController;
18+
export const ByteLengthQueuingStrategy = globalThis.ByteLengthQueuingStrategy;
19+
export const CountQueuingStrategy = globalThis.CountQueuingStrategy;
20+
export const TextEncoderStream = globalThis.TextEncoderStream;
21+
export const TextDecoderStream = globalThis.TextDecoderStream;
22+
export const CompressionStream = globalThis.CompressionStream;
23+
export const DecompressionStream = globalThis.DecompressionStream;
2524

2625
export default {
2726
ReadableStream,

src/workerd/api/node/streams-test.js

+5
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,11 @@ import {
3838
promises,
3939
} from 'node:stream';
4040

41+
import {
42+
ByteLengthQueuingStrategy,
43+
} from 'node:stream/web';
44+
strictEqual(ByteLengthQueuingStrategy, globalThis.ByteLengthQueuingStrategy);
45+
4146
import {
4247
EventEmitter,
4348
} from 'node:events';

0 commit comments

Comments
 (0)