diff options
| author |  Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-12-02 20:15:50 -0800 |
|---|---|---|
| committer | Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-12-02 20:15:50 -0800 |
| commit | d9f9fc975beb9d5d8fe83f6ed2a084c36846522b (patch) | |
| tree | 65b9a71aaea04222bd7c7631f25c5f698c11c26c /src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp | |
| parent | bdbc0f23e7235b1b1c9e24d251613f3b477a8abd (diff) | |
| download | bun-d9f9fc975beb9d5d8fe83f6ed2a084c36846522b.tar.gz bun-d9f9fc975beb9d5d8fe83f6ed2a084c36846522b.tar.zst bun-d9f9fc975beb9d5d8fe83f6ed2a084c36846522b.zip | |
Propagate reason in AbortSignal and reuse in ReadableStream.pipeTo
Similar to https://github.com/WebKit/WebKit/pull/7013
Diffstat (limited to 'src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp')
| -rw-r--r-- | src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp index a957a7c2b..c231091b6 100644 --- a/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp +++ b/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp @@ -392,14 +392,16 @@ const char* const s_streamInternalsResetQueueCode = const JSC::ConstructAbility s_streamInternalsExtractSizeAlgorithmCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_streamInternalsExtractSizeAlgorithmCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_streamInternalsExtractSizeAlgorithmCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_streamInternalsExtractSizeAlgorithmCodeLength = 288; +const int s_streamInternalsExtractSizeAlgorithmCodeLength = 294; static const JSC::Intrinsic s_streamInternalsExtractSizeAlgorithmCodeIntrinsic = JSC::NoIntrinsic; const char* const s_streamInternalsExtractSizeAlgorithmCode = "(function (strategy)\n" \ "{\n" \ - " if (!(\"size\" in strategy))\n" \ + " const sizeAlgorithm = strategy.size;\n" \ + "\n" \ + " if (sizeAlgorithm === @undefined)\n" \ " return () => 1;\n" \ - " const sizeAlgorithm = strategy[\"size\"];\n" \ + "\n" \ " if (typeof sizeAlgorithm !== \"function\")\n" \ " @throwTypeError(\"strategy.size must be a function\");\n" \ "\n" \ @@ -410,14 +412,16 @@ const char* const s_streamInternalsExtractSizeAlgorithmCode = const JSC::ConstructAbility s_streamInternalsExtractHighWaterMarkCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_streamInternalsExtractHighWaterMarkCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_streamInternalsExtractHighWaterMarkCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_streamInternalsExtractHighWaterMarkCodeLength = 325; +const int s_streamInternalsExtractHighWaterMarkCodeLength = 322; static const JSC::Intrinsic s_streamInternalsExtractHighWaterMarkCodeIntrinsic = JSC::NoIntrinsic; const char* const s_streamInternalsExtractHighWaterMarkCode = "(function (strategy, defaultHWM)\n" \ "{\n" \ - " if (!(\"highWaterMark\" in strategy))\n" \ + " const highWaterMark = strategy.highWaterMark;\n" \ + "\n" \ + " if (highWaterMark === @undefined)\n" \ " return defaultHWM;\n" \ - " const highWaterMark = strategy[\"highWaterMark\"];\n" \ + "\n" \ " if (@isNaN(highWaterMark) || highWaterMark < 0)\n" \ " @throwRangeError(\"highWaterMark value is negative or not a number\");\n" \ "\n" \ |