diff options
| author | 2023-05-08 18:10:40 -0300 | |
|---|---|---|
| committer | 2023-05-08 14:10:40 -0700 | |
| commit | c6c21eeba749a5ebbc7a3f9dc3a0f7e5a702e0da (patch) | |
| tree | a6f7b5b616e492ace2439dfca9544f157e2fcb03 /src/deps/libuwsockets.cpp | |
| parent | 14597dbcdc318439d1ba3a7bdbf20d7b5d3c51ef (diff) | |
| download | bun-c6c21eeba749a5ebbc7a3f9dc3a0f7e5a702e0da.tar.gz bun-c6c21eeba749a5ebbc7a3f9dc3a0f7e5a702e0da.tar.zst bun-c6c21eeba749a5ebbc7a3f9dc3a0f7e5a702e0da.zip | |
added some improvements on server (#2803)
* added some improvements on server
* undo unintended change
* clean data handler before end calls
* refactor
* make ctx.resp nullable
---------
Co-authored-by: Jarred Sumner <jarred@jarredsumner.com>
Diffstat (limited to 'src/deps/libuwsockets.cpp')
| -rw-r--r-- | src/deps/libuwsockets.cpp | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/src/deps/libuwsockets.cpp b/src/deps/libuwsockets.cpp index cbf399f20..1533787ee 100644 --- a/src/deps/libuwsockets.cpp +++ b/src/deps/libuwsockets.cpp @@ -1261,14 +1261,22 @@ extern "C" if (ssl) { uWS::HttpResponse<true> *uwsRes = (uWS::HttpResponse<true> *)res; - uwsRes->onData([handler, res, opcional_data](auto chunk, bool is_end) - { handler(res, chunk.data(), chunk.length(), is_end, opcional_data); }); + if (handler) { + uwsRes->onData([handler, res, opcional_data](auto chunk, bool is_end) + { handler(res, chunk.data(), chunk.length(), is_end, opcional_data); }); + } else { + uwsRes->onData(nullptr); + } } else { uWS::HttpResponse<false> *uwsRes = (uWS::HttpResponse<false> *)res; - uwsRes->onData([handler, res, opcional_data](auto chunk, bool is_end) - { handler(res, chunk.data(), chunk.length(), is_end, opcional_data); }); + if (handler) { + uwsRes->onData([handler, res, opcional_data](auto chunk, bool is_end) + { handler(res, chunk.data(), chunk.length(), is_end, opcional_data); }); + } else { + uwsRes->onData(nullptr); + } } } |
