diff options
author | 2023-09-04 16:26:49 -0300 | |
---|---|---|
committer | 2023-09-04 12:26:49 -0700 | |
commit | 2d80f94edafe09329b027424b32908632694553d (patch) | |
tree | e7de3a4fa31096a26d4dda37eedf18cb51a902a1 /src/bun.js/bindings/ZigGlobalObject.cpp | |
parent | 18767906db0dd29b2d898f84a023d403c3084d6e (diff) | |
download | bun-2d80f94edafe09329b027424b32908632694553d.tar.gz bun-2d80f94edafe09329b027424b32908632694553d.tar.zst bun-2d80f94edafe09329b027424b32908632694553d.zip |
fix(HTMLRewriter) buffer response before transform (#4418)
* html rewriter response buffering
* pipe the data when marked as used
* fix empty response
* add some fetch tests
* deinit parent stream
* fix decompression
* keep byte_reader alive
* update builds
* remove nonsense
* was not nonsense after all
* protect tmp ret value from GC, fix readable strong ref deinit/init
* fmt
* if we detach the stream we cannot update the fetch stream
* detach checking source
* more tests, progress with javascript and Direct sink
* drop support for pure readable stream for now
* more fixes
---------
Co-authored-by: Jarred Sumner <jarred@jarredsumner.com>
Diffstat (limited to 'src/bun.js/bindings/ZigGlobalObject.cpp')
-rw-r--r-- | src/bun.js/bindings/ZigGlobalObject.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/bun.js/bindings/ZigGlobalObject.cpp b/src/bun.js/bindings/ZigGlobalObject.cpp index 467667953..7edbd42e6 100644 --- a/src/bun.js/bindings/ZigGlobalObject.cpp +++ b/src/bun.js/bindings/ZigGlobalObject.cpp @@ -4419,6 +4419,10 @@ GlobalObject::PromiseFunctions GlobalObject::promiseHandlerID(EncodedJSValue (*h return GlobalObject::PromiseFunctions::CallbackJob__onResolve; } else if (handler == CallbackJob__onReject) { return GlobalObject::PromiseFunctions::CallbackJob__onReject; + } else if (handler == Bun__BodyValueBufferer__onResolveStream) { + return GlobalObject::PromiseFunctions::Bun__BodyValueBufferer__onResolveStream; + } else if (handler == Bun__BodyValueBufferer__onRejectStream) { + return GlobalObject::PromiseFunctions::Bun__BodyValueBufferer__onRejectStream; } else { RELEASE_ASSERT_NOT_REACHED(); } |