aboutsummaryrefslogtreecommitdiff
path: root/src/deps/libuwsockets.cpp
diff options
context:
space:
mode:
authorGravatar Ciro Spaciari <ciro.spaciari@gmail.com> 2023-05-08 18:10:40 -0300
committerGravatar GitHub <noreply@github.com> 2023-05-08 14:10:40 -0700
commitc6c21eeba749a5ebbc7a3f9dc3a0f7e5a702e0da (patch)
treea6f7b5b616e492ace2439dfca9544f157e2fcb03 /src/deps/libuwsockets.cpp
parent14597dbcdc318439d1ba3a7bdbf20d7b5d3c51ef (diff)
downloadbun-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.cpp16
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);
+ }
}
}