Inheritance diagram for JEventTapArrow:

Collaboration diagram for JEventTapArrow:

Public Types
enum	PortIndex { EVENT_IN =0 , EVENT_OUT =1 }

Public Types inherited from JArrow
enum class	FireResult { NotRunYet , KeepGoing , ComeBackLater , Finished }

using	OutputData = std::array< std::pair< JEvent *, int >, 2 >

Public Member Functions
	JEventTapArrow (std::string name)

void	add_processor (JEventProcessor *proc)

void	fire (JEvent *event, OutputData &outputs, size_t &output_count, JArrow::FireResult &status) final

void	initialize () final

void	finalize () final

Public Member Functions inherited from JArrow
const std::string &	get_name ()

JLogger &	get_logger ()

bool	is_parallel ()

bool	is_source ()

bool	is_sink ()

Port &	get_port (size_t port_index)

int	get_next_port_index ()

void	set_name (std::string name)

void	set_logger (JLogger logger)

void	set_is_parallel (bool is_parallel)

void	set_is_source (bool is_source)

void	set_is_sink (bool is_sink)

	JArrow (std::string name, bool is_parallel, bool is_source, bool is_sink)

virtual FireResult	execute (size_t location_id)

void	create_ports (size_t inputs, size_t outputs)

void	attach (JEventQueue *queue, size_t port)

void	attach (JEventPool *pool, size_t port)

JEvent *	pull (size_t input_port, size_t location_id)

void	push (OutputData &outputs, size_t output_count, size_t location_id)

Additional Inherited Members
Protected Types inherited from JArrow
using	clock_t = std::chrono::steady_clock

Protected Attributes inherited from JArrow
int	m_next_input_port =0

clock_t::time_point	m_next_visit_time =clock_t::now()

std::vector< Port >	m_ports

JLogger	m_logger

Member Function Documentation

◆ finalize()

void JEventTapArrow::finalize ( )

finalvirtual

Reimplemented from JArrow.

finalvirtual

Reimplemented from JArrow.

void JEventTapArrow::initialize ( )

finalvirtual

Reimplemented from JArrow.

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