@@ -172,10 +172,10 @@ SSEClient::SSEClient(
172172 const RestconfNotificationWatcher& eventWatcher,
173173 const std::string& uri,
174174 const std::map<std::string, std::string>& headers,
175- const boost::posix_time ::seconds silenceTimeout,
175+ const std::chrono ::seconds silenceTimeout,
176176 const ReportIgnoredLines reportIgnoredLines)
177177 : client(std::make_shared<ng_client::session>(io, server_address, server_port))
178- , t(io, silenceTimeout)
178+ , t(io, std::chrono::seconds( silenceTimeout) )
179179{
180180 ng::header_map reqHeaders;
181181 for (const auto & [name, value] : headers) {
@@ -201,7 +201,7 @@ SSEClient::SSEClient(
201201 res.on_data ([&, silenceTimeout, reportIgnoredLines](const uint8_t * data, std::size_t len) {
202202 dataBuffer.append (std::string (reinterpret_cast <const char *>(data), len));
203203 parseEvents (eventWatcher, reportIgnoredLines);
204- t.expires_from_now ( silenceTimeout);
204+ t.expires_after ( std::chrono::seconds ( silenceTimeout) );
205205 });
206206 });
207207
0 commit comments