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 94 of file MqttModel.h.

Constructor & Destructor Documentation

EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::EventReceiver

(

const std::shared_ptr< express::Response > &

response

)

Definition at line 182 of file MqttModel.cpp.

        : response(response)
        , heartbeatTimer(core::timer::Timer::intervalTimer(
              [response] {
                  response->sendFragment(":keep-alive");
                  response->sendFragment();
              },
              39)) {
    }

References heartbeatTimer, and response.

~EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::~EventReceiver

(

)

Definition at line 192 of file MqttModel.cpp.

                                           {
        heartbeatTimer.cancel();
    }

References heartbeatTimer.

Member Function Documentation

operator==()

bool mqtt::mqttbroker::lib::MqttModel::EventReceiver::operator==

(

const EventReceiver &

other

)

Definition at line 196 of file MqttModel.cpp.

                                                                      {
        return response.lock() == other.response.lock();
    }

References response.

Member Data Documentation

heartbeatTimer

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

Definition at line 104 of file MqttModel.h.

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

response

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

Definition at line 100 of file MqttModel.h.

Referenced by EventReceiver(), operator==(), and mqtt::mqttbroker::lib::MqttModel::sendEvent().

---

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

• mqttbroker/lib/MqttModel.h
• mqttbroker/lib/MqttModel.cpp