Repository navigation
SSE (Server Sent Events) implementation #11
Description
Activity
The exception could be coming from when our internal implementation tries to read from the dataStream (since it is an output stream).
You might want to use a producer_consumer_buffer here. Then you can write to the buffer and our internal implementation can read from the buffer and send the data.
streams::producer_consumer_buffer<char> rwbuf; streams::basic_istream<uint8_t> stream(rwbuf); response.set_body(stream); auto rep = request.reply(response); rwbuf.putn_nocopy("data", length).wait(); rwbuf.putn_nocopy("data2", length2).wait(); rwbuf.sync().wait(); rwbuf.putn_nocopy("data3", length).wait(); rwbuf.close(std::ios_base::out).wait(); rep.wait();Here, calling sync() will ensure the data is sent out and closing the buffer will complete the response.
Thanks Kavya Kotacherry - MSFT (@kavyako), the proposed solution worked.
Implementation of SSE(Server sent event ) is possible using rest HTTP servers ?
Hi ... I was able to implement Server Sent Event(SSE) using above proposed solution.
Now I am stuck on how to determine whether underlying connection is still active before writing SSE data on stream.
It is very urgent can u please suggest a way determine whether SSE connection is active or not.
Hi, I would like to know if it is possible to implement an SSE protocol on top of Casablanca, the main idea would be to send multiple replies to an
web::http::http_requestobject whenever new data arrives to be distributed to a connected client, since I cannot use thereply()method multiple times what would be the right way to do it?I have also tried to use the
set_response_streammethod onweb::http::http_requestbut I have an exception in this case. Is it doable using Casablanca?Thanks for your attention,