mqtt::bridge::lib::SSEDistributor::EventReceiver Class Reference

Collaboration diagram for mqtt::bridge::lib::SSEDistributor::EventReceiver:

Public Member Functions
	EventReceiver (std::uint64_t id, const std::shared_ptr< express::Response > &response)
	~EventReceiver ()
std::shared_ptr< express::Response >	getResponse () const
std::uint64_t	getId () const

Private Attributes
std::uint64_t	id
std::weak_ptr< express::Response >	response
core::timer::Timer	heartbeatTimer

Detailed Description

Definition at line 65 of file SSEDistributor.h.

Constructor & Destructor Documentation

EventReceiver()

mqtt::bridge::lib::SSEDistributor::EventReceiver::EventReceiver	(	std::uint64_t	id,
		const std::shared_ptr< express::Response > &	response )

Definition at line 247 of file SSEDistributor.cpp.

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

References heartbeatTimer, id, and response.

~EventReceiver()

mqtt::bridge::lib::SSEDistributor::EventReceiver::~EventReceiver

(

)

Definition at line 258 of file SSEDistributor.cpp.

                                                {
        heartbeatTimer.cancel();
    }

References heartbeatTimer.

Member Function Documentation

getId()

std::uint64_t mqtt::bridge::lib::SSEDistributor::EventReceiver::getId ( ) const

inline

Definition at line 73 of file SSEDistributor.h.

                                      {
                return id;
            }

References id.

Referenced by mqtt::bridge::lib::SSEDistributor::addEventReceiver().

Here is the caller graph for this function:

getResponse()

std::shared_ptr< express::Response > mqtt::bridge::lib::SSEDistributor::EventReceiver::getResponse

(

)

const

Definition at line 262 of file SSEDistributor.cpp.

                                                                                  {
        return response.lock();
    }

References response.

Referenced by mqtt::bridge::lib::SSEDistributor::sendEvent().

Here is the caller graph for this function:

Member Data Documentation

heartbeatTimer

core::timer::Timer mqtt::bridge::lib::SSEDistributor::EventReceiver::heartbeatTimer

private

Definition at line 81 of file SSEDistributor.h.

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

id

std::uint64_t mqtt::bridge::lib::SSEDistributor::EventReceiver::id

private

Definition at line 78 of file SSEDistributor.h.

Referenced by EventReceiver(), and getId().

response

std::weak_ptr<express::Response> mqtt::bridge::lib::SSEDistributor::EventReceiver::response

private

Definition at line 79 of file SSEDistributor.h.

Referenced by EventReceiver(), and getResponse().

---

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

• mqttbridge/lib/SSEDistributor.h
• mqttbridge/lib/SSEDistributor.cpp