Archives/ohwgiles_laminar
1
0
Fork 0
mirror of https://github.com/ohwgiles/laminar.git synced 2025-06-13 12:54:29 +00:00
Code Issues Projects Releases Wiki Activity

sse endpoint: hint to reverse-proxy not to buffer

Browse Source 
Similarly to 210787a3, and as discussed in #88 and #130, nginx
will buffer chunked transfer-encoding unless proxy_buffering
is turned off or the X-Accel-Buffering header is set to no.

resolves #130
This commit is contained in:
Oliver Giles 2020-08-11 06:54:03 +12:00
parent 8a4992e6af
commit 4316eb8a00
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/http.cpp
View File

@ -203,6 +203,8 @@ kj::Promise<void> Http::request(kj::HttpMethod method, kj::StringPtr url, const
if(is_sse) { if(is_sse) {
KJ_IF_MAYBE(s, fromUrl(url.cStr(), queryString)) { KJ_IF_MAYBE(s, fromUrl(url.cStr(), queryString)) {
responseHeaders.set(kj::HttpHeaderId::CONTENT_TYPE, "text/event-stream"); responseHeaders.set(kj::HttpHeaderId::CONTENT_TYPE, "text/event-stream");
// Disables nginx reverse-proxy's buffering. Necessary for streamed events.
responseHeaders.add("X-Accel-Buffering", "no");
auto peer = kj::heap<WithSetRef<EventPeer>>(eventPeers); auto peer = kj::heap<WithSetRef<EventPeer>>(eventPeers);
peer->scope = *s; peer->scope = *s;
std::string st = "data: " + laminar.getStatus(peer->scope) + "\n\n"; std::string st = "data: " + laminar.getStatus(peer->scope) + "\n\n";