pion::plugins::FeedWriter Class Reference

#include <FeedService.hpp>

Inherits pion::plugins::FeedHandler.

List of all members.

---

Detailed Description

FeedWriter: helper class used to send Events over a TCP connection

Definition at line 127 of file FeedService.hpp.

Public Member Functions
virtual	~FeedWriter ()
	virtual destructor
	FeedWriter (pion::platform::ReactionEngine &reaction_engine, const std::string &reactor_id, pion::platform::CodecPtr &codec_ptr, pion::net::TCPConnectionPtr &tcp_conn)
void	writeEvent (pion::platform::EventPtr &e)
virtual void	start (void)
	starts the FeedWriter

---

Constructor & Destructor Documentation

pion::plugins::FeedWriter::FeedWriter	(	pion::platform::ReactionEngine &	reaction_engine,
		const std::string &	reactor_id,
		pion::platform::CodecPtr &	codec_ptr,
		pion::net::TCPConnectionPtr &	tcp_conn
	)

constructs a new FeedWriter object

Parameters:

	reactor_id	unique identifier for the Reactor that this handler interacts with
	codec_ptr	pointer to the Codec that this handler will use
	tcp_conn	TCP connection that will be used to send/receive Events

Definition at line 88 of file FeedService.cpp.

---

Member Function Documentation

void pion::plugins::FeedWriter::writeEvent

(

pion::platform::EventPtr &

e

)

sends an Event over the TCP connection and cleans up if the connection has closed since we last sent data

Parameters:

e

the Event to send over the TCPConnection

Definition at line 100 of file FeedService.cpp.

References pion::net::TCPStream::close(), pion::platform::EventPtr::get(), pion::plugins::FeedHandler::getConnectionId(), pion::plugins::FeedHandler::getConnectionInfo(), pion::plugins::FeedHandler::m_codec_ptr, pion::plugins::FeedHandler::m_logger, pion::plugins::FeedHandler::m_mutex, pion::plugins::FeedHandler::m_reaction_engine, pion::plugins::FeedHandler::m_tcp_conn, pion::plugins::FeedHandler::m_tcp_stream, and pion::platform::ReactionEngine::post().

Referenced by start().

---

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

• platform/services/FeedService.hpp
• platform/services/FeedService.cpp

---