diff options
author | 2023-06-01 21:16:47 -0400 | |
---|---|---|
committer | 2023-06-01 18:16:47 -0700 | |
commit | 4df1d37ddc54242c339765f22fb90ba2e9e3a99a (patch) | |
tree | d63ede76463e7ecba78a4d4b31e5e8158193552f /src/js/builtins/WritableStreamDefaultWriter.ts | |
parent | 03ffd1c732aaaa30b5481f197221ce96da559e63 (diff) | |
download | bun-4df1d37ddc54242c339765f22fb90ba2e9e3a99a.tar.gz bun-4df1d37ddc54242c339765f22fb90ba2e9e3a99a.tar.zst bun-4df1d37ddc54242c339765f22fb90ba2e9e3a99a.zip |
Bundle and minify `.exports.js` files. (#3036)
* move all exports.js into src/js
* finalize the sort of this
* and it works
* add test.ts to gitignore
* okay
* convert some to ts just to show
* finish up
* fixup makefile
* minify syntax in dev
* finish rebase
* dont minify all modules
* merge
* finish rebase merge
* flaky test that hangs
Diffstat (limited to 'src/js/builtins/WritableStreamDefaultWriter.ts')
-rw-r--r-- | src/js/builtins/WritableStreamDefaultWriter.ts | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/src/js/builtins/WritableStreamDefaultWriter.ts b/src/js/builtins/WritableStreamDefaultWriter.ts new file mode 100644 index 000000000..795b43892 --- /dev/null +++ b/src/js/builtins/WritableStreamDefaultWriter.ts @@ -0,0 +1,104 @@ +/* + * Copyright (C) 2020 Apple Inc. All rights reserved. + * + * 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. AND ITS CONTRIBUTORS ``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 ITS 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 initializeWritableStreamDefaultWriter(stream) { + // stream can be a WritableStream if WritableStreamDefaultWriter constructor is called directly from JS + // or an InternalWritableStream in other code paths. + const internalStream = $getInternalWritableStream(stream); + if (internalStream) stream = internalStream; + + if (!$isWritableStream(stream)) $throwTypeError("WritableStreamDefaultWriter constructor takes a WritableStream"); + + $setUpWritableStreamDefaultWriter(this, stream); + return this; +} + +$getter; +export function closed() { + if (!$isWritableStreamDefaultWriter(this)) + return Promise.$reject($makeGetterTypeError("WritableStreamDefaultWriter", "closed")); + + return $getByIdDirectPrivate(this, "closedPromise").$promise; +} + +$getter; +export function desiredSize() { + if (!$isWritableStreamDefaultWriter(this)) throw $makeThisTypeError("WritableStreamDefaultWriter", "desiredSize"); + + if ($getByIdDirectPrivate(this, "stream") === undefined) $throwTypeError("WritableStreamDefaultWriter has no stream"); + + return $writableStreamDefaultWriterGetDesiredSize(this); +} + +$getter; +export function ready() { + if (!$isWritableStreamDefaultWriter(this)) + return Promise.$reject($makeThisTypeError("WritableStreamDefaultWriter", "ready")); + + return $getByIdDirectPrivate(this, "readyPromise").$promise; +} + +export function abort(reason) { + if (!$isWritableStreamDefaultWriter(this)) + return Promise.$reject($makeThisTypeError("WritableStreamDefaultWriter", "abort")); + + if ($getByIdDirectPrivate(this, "stream") === undefined) + return Promise.$reject($makeTypeError("WritableStreamDefaultWriter has no stream")); + + return $writableStreamDefaultWriterAbort(this, reason); +} + +export function close() { + if (!$isWritableStreamDefaultWriter(this)) + return Promise.$reject($makeThisTypeError("WritableStreamDefaultWriter", "close")); + + const stream = $getByIdDirectPrivate(this, "stream"); + if (stream === undefined) return Promise.$reject($makeTypeError("WritableStreamDefaultWriter has no stream")); + + if ($writableStreamCloseQueuedOrInFlight(stream)) + return Promise.$reject($makeTypeError("WritableStreamDefaultWriter is being closed")); + + return $writableStreamDefaultWriterClose(this); +} + +export function releaseLock() { + if (!$isWritableStreamDefaultWriter(this)) throw $makeThisTypeError("WritableStreamDefaultWriter", "releaseLock"); + + const stream = $getByIdDirectPrivate(this, "stream"); + if (stream === undefined) return; + + $assert($getByIdDirectPrivate(stream, "writer") !== undefined); + $writableStreamDefaultWriterRelease(this); +} + +export function write(chunk) { + if (!$isWritableStreamDefaultWriter(this)) + return Promise.$reject($makeThisTypeError("WritableStreamDefaultWriter", "write")); + + if ($getByIdDirectPrivate(this, "stream") === undefined) + return Promise.$reject($makeTypeError("WritableStreamDefaultWriter has no stream")); + + return $writableStreamDefaultWriterWrite(this, chunk); +} |