diff options
Diffstat (limited to 'extensions/web')
| -rw-r--r-- | extensions/web/06_streams.js | 8 | ||||
| -rw-r--r-- | extensions/web/internal.d.ts | 1 |
2 files changed, 9 insertions, 0 deletions
diff --git a/extensions/web/06_streams.js b/extensions/web/06_streams.js index be5eca6ba..127436d43 100644 --- a/extensions/web/06_streams.js +++ b/extensions/web/06_streams.js @@ -4246,6 +4246,13 @@ webidl.configurePrototype(WritableStreamDefaultController); + /** + * @param {ReadableStream} stream + */ + function createProxy(stream) { + return stream.pipeThrough(new TransformStream()); + } + webidl.converters.ReadableStream = webidl .createInterfaceConverter("ReadableStream", ReadableStream); webidl.converters.WritableStream = webidl @@ -4403,6 +4410,7 @@ // Non-Public isReadableStreamDisturbed, errorReadableStream, + createProxy, // Exposed in global runtime scope ByteLengthQueuingStrategy, CountQueuingStrategy, diff --git a/extensions/web/internal.d.ts b/extensions/web/internal.d.ts index 06976b28b..bbf529b77 100644 --- a/extensions/web/internal.d.ts +++ b/extensions/web/internal.d.ts @@ -81,6 +81,7 @@ declare namespace globalThis { declare var streams: { ReadableStream: typeof ReadableStream; isReadableStreamDisturbed(stream: ReadableStream): boolean; + createProxy<T>(stream: ReadableStream<T>): ReadableStream<T>; }; declare namespace messagePort { |