taraxa::net::Subscriptions Class Reference

#include <subscriptions.hpp>

Collaboration diagram for taraxa::net::Subscriptions:

Public Member Functions
	Subscriptions (std::function< void(std::string &&)> send)
int	addSubscription (std::shared_ptr< Subscription > subscription)
bool	removeSubscription (int id)
void	process (SubscriptionType type, const Json::Value &payload)
void	processLogs (const final_chain::BlockHeader &header, TransactionHashes trx_hashes, const TransactionReceipts &receipts)

Private Attributes
std::function< void(std::string &&)>	send_
std::map< uint64_t, std::shared_ptr< Subscription > >	subscriptions_
std::map< SubscriptionType, std::list< uint64_t > >	subscriptions_by_type_
std::mutex	subscriptions_mutex_

Constructor & Destructor Documentation

Subscriptions()

taraxa::net::Subscriptions::Subscriptions ( std::function< void(std::string &&)>  send )

inline

Member Function Documentation

addSubscription()

int taraxa::net::Subscriptions::addSubscription

(

std::shared_ptr< Subscription >

subscription

)

process()

void taraxa::net::Subscriptions::process	(	SubscriptionType	type,
		const Json::Value &	payload
	)

processLogs()

void taraxa::net::Subscriptions::processLogs	(	const final_chain::BlockHeader &	header,
		TransactionHashes	trx_hashes,
		const TransactionReceipts &	receipts
	)

removeSubscription()

bool taraxa::net::Subscriptions::removeSubscription

(

int

id

)

Member Data Documentation

send_

std::function<void(std::string&&)> taraxa::net::Subscriptions::send_

private

subscriptions_

std::map<uint64_t, std::shared_ptr<Subscription> > taraxa::net::Subscriptions::subscriptions_

private

subscriptions_by_type_

std::map<SubscriptionType, std::list<uint64_t> > taraxa::net::Subscriptions::subscriptions_by_type_

private

subscriptions_mutex_

std::mutex taraxa::net::Subscriptions::subscriptions_mutex_

private

---

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

• libraries/core_libs/network/include/network/subscriptions.hpp
• libraries/core_libs/network/src/subscriptions.cpp