5 #ifndef CVMFS_NOTIFY_SUBSCRIBER_SSE_H_
6 #define CVMFS_NOTIFY_SUBSCRIBER_SSE_H_
35 virtual bool Subscribe(
const std::string& topic);
54 static int CurlProgressCB(
void* clientp, curl_off_t dltotal, curl_off_t dlnow,
55 curl_off_t ultotal, curl_off_t ulnow);
66 #endif // CVMFS_NOTIFY_SUBSCRIBER_SSE_H_
virtual void Unsubscribe()
static int CurlProgressCB(void *clientp, curl_off_t dltotal, curl_off_t dlnow, curl_off_t ultotal, curl_off_t ulnow)
void AppendToBuffer(const std::string &s)
atomic_int32 should_quit_
static size_t CurlRecvCB(void *buffer, size_t size, size_t nmemb, void *userp)
virtual bool Subscribe(const std::string &topic)
SubscriberSSE(const std::string &server_url)