MQTTSuite
Loading...
Searching...
No Matches
mqtt::mqttbroker::lib::MqttModel::EventReceiver Class Reference
Collaboration diagram for mqtt::mqttbroker::lib::MqttModel::EventReceiver:

Public Member Functions

 EventReceiver (const std::shared_ptr< express::Response > &response)
 ~EventReceiver ()
bool operator== (const EventReceiver &other)

Public Attributes

std::weak_ptr< express::Response > response
core::timer::Timer heartbeatTimer

Detailed Description

Definition at line 77 of file MqttModel.h.

Constructor & Destructor Documentation

◆ EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::EventReceiver ( const std::shared_ptr< express::Response > & response)

Definition at line 158 of file MqttModel.cpp.

160 , heartbeatTimer(core::timer::Timer::intervalTimer(
161 [response] {
162 response->sendFragment(":keep-alive");
163 response->sendFragment();
164 },
165 39)) {
166 }
std::weak_ptr< express::Response > response
Definition MqttModel.h:83

References heartbeatTimer, and response.

◆ ~EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::~EventReceiver ( )

Definition at line 168 of file MqttModel.cpp.

168 {
169 heartbeatTimer.cancel();
170 }

References heartbeatTimer.

Member Function Documentation

◆ operator==()

bool mqtt::mqttbroker::lib::MqttModel::EventReceiver::operator== ( const EventReceiver & other)

Definition at line 172 of file MqttModel.cpp.

172 {
173 return response.lock() == other.response.lock();
174 }

References response.

Member Data Documentation

◆ heartbeatTimer

core::timer::Timer mqtt::mqttbroker::lib::MqttModel::EventReceiver::heartbeatTimer

Definition at line 87 of file MqttModel.h.

Referenced by EventReceiver(), and ~EventReceiver().

◆ response

std::weak_ptr<express::Response> mqtt::mqttbroker::lib::MqttModel::EventReceiver::response

The documentation for this class was generated from the following files: