Chatterino
|
Public Member Functions | |
MyManager (QString host) | |
std::optional< QString > | popMessage () |
void | sub (const DummySubscription &sub) |
void | unsub (const DummySubscription &sub) |
![]() | |
BasicPubSubManager (QString host) | |
BasicPubSubManager (const BasicPubSubManager &)=delete | |
BasicPubSubManager (const BasicPubSubManager &&)=delete | |
virtual | ~BasicPubSubManager ()=default |
BasicPubSubManager & | operator= (const BasicPubSubManager &)=delete |
BasicPubSubManager & | operator= (const BasicPubSubManager &&)=delete |
void | start () |
void | stop () |
Public Attributes | |
std::atomic< int32_t > | messagesReceived {0} |
![]() | |
std::atomic< uint32_t > | connectionsClosed |
std::atomic< uint32_t > | connectionsOpened |
std::atomic< uint32_t > | connectionsFailed |
struct { | |
std::atomic< uint32_t > connectionsClosed {0} | |
std::atomic< uint32_t > connectionsOpened {0} | |
std::atomic< uint32_t > connectionsFailed {0} | |
} | diag |
Protected Member Functions | |
void | onMessage (websocketpp::connection_hdl, BasicPubSubManager< DummySubscription >::WebsocketMessagePtr msg) override |
![]() | |
virtual void | onMessage (websocketpp::connection_hdl hdl, WebsocketMessagePtr msg)=0 |
virtual std::shared_ptr< BasicPubSubClient< DummySubscription > > | createClient (liveupdates::WebsocketClient &client, websocketpp::connection_hdl hdl) |
std::shared_ptr< BasicPubSubClient< DummySubscription > > | findClient (websocketpp::connection_hdl hdl) |
void | unsubscribe (const DummySubscription &subscription) |
void | subscribe (const DummySubscription &subscription) |
Additional Inherited Members | |
![]() | |
using | WebsocketMessagePtr = websocketpp::config::asio_tls_client::message_type::ptr |
using | WebsocketContextPtr = websocketpp::lib::shared_ptr< boost::asio::ssl::context > |
|
inline |
|
inlineoverrideprotected |
|
inline |
|
inline |
|
inline |
std::atomic<int32_t> MyManager::messagesReceived {0} |