/* * Copyright (C) 2015 Canon Inc. * Copyright (C) 2015 Igalia. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ export function initializeReadableStream(this: any, underlyingSource: UnderlyingSource, strategy: any) { if (underlyingSource === undefined) underlyingSource = { $bunNativeType: 0, $bunNativePtr: 0, $lazy: false } as UnderlyingSource; if (strategy === undefined) strategy = {}; if (!$isObject(underlyingSource)) throw new TypeError("ReadableStream constructor takes an object as first argument"); if (strategy !== undefined && !$isObject(strategy)) throw new TypeError("ReadableStream constructor takes an object as second argument, if any"); $putByIdDirectPrivate(this, "state", $streamReadable); $putByIdDirectPrivate(this, "reader", undefined); $putByIdDirectPrivate(this, "storedError", undefined); $putByIdDirectPrivate(this, "disturbed", false); // Initialized with null value to enable distinction with undefined case. $putByIdDirectPrivate(this, "readableStreamController", null); $putByIdDirectPrivate(this, "bunNativeType", $getByIdDirectPrivate(underlyingSource, "bunNativeType") ?? 0); $putByIdDirectPrivate(this, "bunNativePtr", $getByIdDirectPrivate(underlyingSource, "bunNativePtr") ?? 0); const isDirect = underlyingSource.type === "direct"; // direct streams are always lazy const isUnderlyingSourceLazy = !!underlyingSource.$lazy; const isLazy = isDirect || isUnderlyingSourceLazy; // FIXME: We should introduce https://streams.spec.whatwg.org/#create-readable-stream. // For now, we emulate this with underlyingSource with private properties. if ($getByIdDirectPrivate(underlyingSource, "pull") !== undefined && !isLazy) { const size = $getByIdDirectPrivate(strategy, "size"); const highWaterMark = $getByIdDirectPrivate(strategy, "highWaterMark"); $putByIdDirectPrivate(this, "highWaterMark", highWaterMark); $putByIdDirectPrivate(this, "underlyingSource", undefined); $setupReadableStreamDefaultController( this, underlyingSource, size, highWaterMark !== undefined ? highWaterMark : 1, $getByIdDirectPrivate(underlyingSource, "start"), $getByIdDirectPrivate(underlyingSource, "pull"), $getByIdDirectPrivate(underlyingSource, "cancel"), ); return this; } if (isDirect) { $putByIdDirectPrivate(this, "underlyingSource", underlyingSource); $putByIdDirectPrivate(this, "highWaterMark", $getByIdDirectPrivate(strategy, "highWaterMark")); $putByIdDirectPrivate(this, "start", () => $createReadableStreamController(this, underlyingSource, strategy)); } else if (isLazy) { const autoAllocateChunkSize = underlyingSource.autoAllocateChunkSize; $putByIdDirectPrivate(this, "highWaterMark", undefined); $putByIdDirectPrivate(this, "underlyingSource", undefined); $putByIdDirectPrivate( this, "highWaterMark", autoAllocateChunkSize || $getByIdDirectPrivate(strategy, "highWaterMark"), ); $putByIdDirectPrivate(this, "start", () => { const instance = $lazyLoadStream(this, autoAllocateChunkSize); if (instance) { $createReadableStreamController(this, instance, strategy); } }); } else { $putByIdDirectPrivate(this, "underlyingSource", undefined); $putByIdDirectPrivate(this, "highWaterMark", $getByIdDirectPrivate(strategy, "highWaterMark")); $putByIdDirectPrivate(this, "start", undefined); $createReadableStreamController(this, underlyingSource, strategy); } return this; } $linkTimeConstant; export function readableStreamToArray(stream: ReadableStream): Promise { // this is a direct stream var underlyingSource = $getByIdDirectPrivate(stream, "underlyingSource"); if (underlyingSource !== undefined) { return $readableStreamToArrayDirect(stream, underlyingSource); } return $readableStreamIntoArray(stream); } $linkTimeConstant; export function readableStreamToText(stream: ReadableStream): Promise { // this is a direct stream var underlyingSource = $getByIdDirectPrivate(stream, "underlyingSource"); if (underlyingSource !== undefined) { return $readableStreamToTextDirect(stream, underlyingSource); } return $readableStreamIntoText(stream); } $linkTimeConstant; export function readableStreamToArrayBuffer(stream: ReadableStream): Promise | ArrayBuffer { // this is a direct stream var underlyingSource = $getByIdDirectPrivate(stream, "underlyingSource"); if (underlyingSource !== undefined) { return $readableStreamToArrayBufferDirect(stream, underlyingSource); } var result = Bun.readableStreamToArray(stream); if ($isPromise(result)) { // `result` is an InternalPromise, which doesn't have a `.$then` method // but `.then` isn't user-overridable, so we can use it safely. return result.then(Bun.concatArrayBuffers); } return Bun.concatArrayBuffers(result); } $linkTimeConstant; export function readableStreamToJSON(stream: ReadableStream): unknown { return Bun.readableStreamToText(stream).$then(globalThis.JSON.parse); } $linkTimeConstant; export function readableStreamToBlob(stream: ReadableStream): Promise { return Promise.resolve(Bun.readableStreamToArray(stream)).$then(array => new Blob(array)); } $linkTimeConstant; export function consumeReadableStream(nativePtr, nativeType, inputStream) { const symbol = globalThis.Symbol.for("Bun.consumeReadableStreamPrototype"); var cached = globalThis[symbol]; if (!cached) { cached = globalThis[symbol] = []; } var Prototype = cached[nativeType]; if (Prototype === undefined) { var [doRead, doError, doReadMany, doClose, onClose, deinit] = globalThis[globalThis.Symbol.for("Bun.lazy")](nativeType); Prototype = class NativeReadableStreamSink { handleError: any; handleClosed: any; processResult: any; constructor(reader, ptr) { this.#ptr = ptr; this.#reader = reader; this.#didClose = false; this.handleError = this._handleError.bind(this); this.handleClosed = this._handleClosed.bind(this); this.processResult = this._processResult.bind(this); reader.closed.then(this.handleClosed, this.handleError); } _handleClosed() { if (this.#didClose) return; this.#didClose = true; var ptr = this.#ptr; this.#ptr = 0; doClose(ptr); deinit(ptr); } _handleError(error) { if (this.#didClose) return; this.#didClose = true; var ptr = this.#ptr; this.#ptr = 0; doError(ptr, error); deinit(ptr); } #ptr; #didClose = false; #reader; _handleReadMany({ value, done, size }) { if (done) { this.handleClosed(); return; } if (this.#didClose) return; doReadMany(this.#ptr, value, done, size); } read() { if (!this.#ptr) return $throwTypeError("ReadableStreamSink is already closed"); return this.processResult(this.#reader.read()); } _processResult(result) { if (result && $isPromise(result)) { const flags = $getPromiseInternalField(result, $promiseFieldFlags); if (flags & $promiseStateFulfilled) { const fulfilledValue = $getPromiseInternalField(result, $promiseFieldReactionsOrResult); if (fulfilledValue) { result = fulfilledValue; } } } if (result && $isPromise(result)) { result.then(this.processResult, this.handleError); return null; } if (result.done) { this.handleClosed(); return 0; } else if (result.value) { return result.value; } else { return -1; } } readMany() { if (!this.#ptr) return $throwTypeError("ReadableStreamSink is already closed"); return this.processResult(this.#reader.readMany()); } }; const minlength = nativeType + 1; if (cached.length < minlength) { cached.length = minlength; } $putByValDirect(cached, nativeType, Prototype); } if ($isReadableStreamLocked(inputStream)) { throw new TypeError("Cannot start reading from a locked stream"); } return new Prototype(inputStream.getReader(), nativePtr); } $linkTimeConstant; export function createEmptyReadableStream() { var stream = new ReadableStream({ pull() {}, } as any); $readableStreamClose(stream); return stream; } $linkTimeConstant; export function createNativeReadableStream(nativePtr, nativeType, autoAllocateChunkSize) { return new ReadableStream({ $lazy: true, $bunNativeType: nativeType, $bunNativePtr: nativePtr, autoAllocateChunkSize: autoAllocateChunkSize, }); } export function cancel(this, reason) { if (!$isReadableStream(this)) return Promise.$reject($makeThisTypeError("ReadableStream", "cancel")); if ($isReadableStreamLocked(this)) return Promise.$reject($makeTypeError("ReadableStream is locked")); return $readableStreamCancel(this, reason); } export function getReader(this, options) { if (!$isReadableStream(this)) throw $makeThisTypeError("ReadableStream", "getReader"); const mode = $toDictionary(options, {}, "ReadableStream.getReader takes an object as first argument").mode; if (mode === undefined) { var start_ = $getByIdDirectPrivate(this, "start"); if (start_) { $putByIdDirectPrivate(this, "start", undefined); start_(); } return new ReadableStreamDefaultReader(this); } // String conversion is required by spec, hence double equals. if (mode == "byob") { return new ReadableStreamBYOBReader(this); } throw new TypeError("Invalid mode is specified"); } export function pipeThrough(this, streams, options) { const transforms = streams; const readable = transforms["readable"]; if (!$isReadableStream(readable)) throw $makeTypeError("readable should be ReadableStream"); const writable = transforms["writable"]; const internalWritable = $getInternalWritableStream(writable); if (!$isWritableStream(internalWritable)) throw $makeTypeError("writable should be WritableStream"); let preventClose = false; let preventAbort = false; let preventCancel = false; let signal; if (!$isUndefinedOrNull(options)) { if (!$isObject(options)) throw $makeTypeError("options must be an object"); preventAbort = !!options["preventAbort"]; preventCancel = !!options["preventCancel"]; preventClose = !!options["preventClose"]; signal = options["signal"]; if (signal !== undefined && !$isAbortSignal(signal)) throw $makeTypeError("options.signal must be AbortSignal"); } if (!$isReadableStream(this)) throw $makeThisTypeError("ReadableStream", "pipeThrough"); if ($isReadableStreamLocked(this)) throw $makeTypeError("ReadableStream is locked"); if ($isWritableStreamLocked(internalWritable)) throw $makeTypeError("WritableStream is locked"); $readableStreamPipeToWritableStream(this, internalWritable, preventClose, preventAbort, preventCancel, signal); return readable; } export function pipeTo(this, destination) { if (!$isReadableStream(this)) return Promise.$reject($makeThisTypeError("ReadableStream", "pipeTo")); if ($isReadableStreamLocked(this)) return Promise.$reject($makeTypeError("ReadableStream is locked")); // FIXME: https://bugs.webkit.org/show_bug.cgi?id=159869. // Built-in generator should be able to parse function signature to compute the function length correctly. let options = $argument(1); let preventClose = false; let preventAbort = false; let preventCancel = false; let signal; if (!$isUndefinedOrNull(options)) { if (!$isObject(options)) return Promise.$reject($makeTypeError("options must be an object")); try { preventAbort = !!options["preventAbort"]; preventCancel = !!options["preventCancel"]; preventClose = !!options["preventClose"]; signal = options["signal"]; } catch (e) { return Promise.$reject(e); } if (signal !== undefined && !$isAbortSignal(signal)) return Promise.$reject(new TypeError("options.signal must be AbortSignal")); } const internalDestination = $getInternalWritableStream(destination); if (!$isWritableStream(internalDestination)) return Promise.$reject(new TypeError("ReadableStream pipeTo requires a WritableStream")); if ($isWritableStreamLocked(internalDestination)) return Promise.$reject(new TypeError("WritableStream is locked")); return $readableStreamPipeToWritableStream( this, internalDestination, preventClose, preventAbort, preventCancel, signal, ); } export function tee(this) { if (!$isReadableStream(this)) throw $makeThisTypeError("ReadableStream", "tee"); return $readableStreamTee(this, false); } $getter; export function locked(this) { if (!$isReadableStream(this)) throw $makeGetterTypeError("ReadableStream", "locked"); return $isReadableStreamLocked(this); } export function values(this, options) { var prototype = ReadableStream.prototype; $readableStreamDefineLazyIterators(prototype); return prototype.values.$call(this, options); } $linkTimeConstant; export function lazyAsyncIterator(this) { var prototype = ReadableStream.prototype; $readableStreamDefineLazyIterators(prototype); return prototype[globalThis.Symbol.asyncIterator].$call(this); } loaders Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/docs/src/layouts (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2021-09-15[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-14Revert "fix bad ci paths"Gravatar Fred K. Schott 1-5/+5
2021-09-15[ci] yarn formatGravatar FredKSchott 1-0/+1
2021-09-14Version Packages (#1358)astro@0.20.6@astrojs/renderer-vue@0.1.8@astrojs/renderer-svelte@0.1.2@astrojs/renderer-solid@0.1.1@astrojs/renderer-react@0.2.1@astrojs/renderer-preact@0.2.2@astrojs/renderer-lit@0.1.1Gravatar github-actions[bot] 41-70/+91
2021-09-14fix bad ci pathsGravatar Fred K. Schott 1-5/+5
2021-09-14update changesetsGravatar Fred K. Schott 1-1/+1
2021-09-14Fix passing Markdown content through props (#1259) (#1343)Gravatar kelvinsjk 4-0/+22
2021-09-14Improve stats logging to use `pretty-bytes` so that 20B doesn't get output as...Gravatar Caleb Jasik 4-2/+13
2021-09-14[ci] yarn formatGravatar FredKSchott 1-1/+1
2021-09-14Merge "Remove check for referenced files" (#1196)Gravatar (none) 6-6/+45
2021-09-14Docs: Add READMEs for renderers (#1351)Gravatar Drew Powers 8-1/+184
2021-09-14Update deployment docs for Netlify deployment (#1361)Gravatar Cassidy Williams 1-7/+9
2021-09-14Delete perfect-kids-occur.md (#1372)Gravatar Fred K. Schott 1-5/+0
2021-09-14[ci] yarn formatGravatar FredKSchott 1-15/+10
2021-09-14Self-host homepage fonts to improve page load speed (#1370)Gravatar mundry 14-5/+52
2021-09-14Add types to examples and docs (#1347)Gravatar Matthew Phillips 8-20/+60
2021-09-14[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-13Fix typo (#1360)Gravatar Marcus Otterström 1-1/+1
2021-09-13Disclaimer for Github pages / jekyll quirk (#1355)Gravatar Tc001 2-0/+7
2021-09-13fix outdated lockfile issue (#1357)Gravatar Fred K. Schott 1-3/+1
2021-09-13Add `astro.build/play` link (#1359)Gravatar Nate Moore 1-0/+6
2021-09-13[ci] yarn formatGravatar FredKSchott 2-8/+7
2021-09-13Add a new lockfile (#1356)Gravatar Matthew Phillips 1-19/+19
2021-09-13[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-12[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-11[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-10Prevent removing CSS preloads during bundling (#1326)Gravatar Bartek Igielski 8-18/+96
2021-09-10Fix typos in Netlify sponsorship announcement blog post (#1346)Gravatar mundry 1-4/+4
2021-09-10[ci] collect statsGravatar FredKSchott 2-1/+2
2021-09-09blog: announce netlify sponsorship (#1345)Gravatar Fred K. Schott 4-5/+64
2021-09-09Version Packages (#1344)Gravatar github-actions[bot] 29-53/+42
2021-09-09Revert "Version Packages (#1303)"Gravatar Fred K. Schott 29-42/+53
2021-09-09update lockfileastro@0.20.5@astrojs/markdown-support@0.3.1Gravatar Fred K. Schott 1-9/+9
2021-09-09Version Packages (#1303)Gravatar github-actions[bot] 29-53/+42
2021-09-09[ci] collect statsGravatar FredKSchott 2-1/+2
2021-09-08Update netlify deploy instructions for `.nvmrc` syntax (#1337)Gravatar Caleb Jasik 1-1/+1
2021-09-08[ci] yarn formatGravatar jasikpark 1-1/+0