11 #include <boost/asio/buffer.hpp>
12 #include <boost/asio/error.hpp>
13 #include <boost/asio/steady_timer.hpp>
14 #include <boost/beast/core/error.hpp>
15 #include <boost/beast/core/multi_buffer.hpp>
16 #include <boost/beast/http/field.hpp>
17 #include <boost/beast/http/serializer.hpp>
18 #include <boost/beast/http/write.hpp>
66         res.set(boost::beast::http::field::content_type, "text/event-stream");  in start()
67         boost::beast::http::response_serializer<BodyType>& serial =  in start()
70         boost::beast::http::async_write_header(  in start()
85         boost::beast::get_lowest_layer(adaptor).close();  in close()
90                                const boost::system::error_code& ec,  in sendSSEHeaderCallback()
110         adaptor.async_read_some(boost::asio::buffer(buffer),  in sendSSEHeaderCallback()
116                         const boost::system::error_code& ec, size_t bytesRead)  in afterReadError()
119         if (ec == boost::asio::error::operation_aborted)  in afterReadError()
152                          const boost::beast::error_code& ec,  in doWriteCallback()
159         if (ec == boost::asio::error::eof)  in doWriteCallback()
219         size_t copied = boost::asio::buffer_copy(  in dataFormat()
220             inputBuffer.prepare(rawData.size()), boost::asio::buffer(rawData));  in dataFormat()
233                            const boost::system::error_code& ec)  in onTimeoutCallback()
243         if (ec == boost::asio::error::operation_aborted)  in onTimeoutCallback()
262     boost::beast::multi_buffer inputBuffer;
267     boost::beast::http::response<BodyType> res;
268     std::optional<boost::beast::http::response_serializer<BodyType>> serializer;
269     boost::asio::steady_timer timer;