Listening for data inputs over a TCP socket. More...

#include <istream.h>

Inheritance diagram for TcpInputStream:

Public Member Functions
	TcpInputStream (int port_num, int dimension)

virtual bool	start () final

virtual void	stop () final

virtual int	getNumInputDimensions () final

Public Member Functions inherited from InputStream
	InputStream ()

virtual	~InputStream ()=default

virtual int	getNumOutputDimensions ()

void	useNormalizer (normalizeFunc f)

void	useNormalizer (vectorNormalizeFunc f)

void	onDataReadyEvent (onDataReadyCallback callback)

template<typename T1 , typename arg , class T >
void	onDataReadyEvent (T1 owner, void(T::listenerMethod)(arg))

void	setLabelsForAllDimensions (const vector< string > labels)

void	setLabelsForAllDimensions (std::initializer_list< string > list)

const vector< string > &	getLabels () const

Public Member Functions inherited from Stream
	Stream ()

void	toggle ()

bool	hasStarted ()

Additional Inherited Members
Public Types inherited from InputStream
using	normalizeFunc = std::function< double(double)>

using	vectorNormalizeFunc = std::function< vector< double >(vector< double >)>

typedef std::function< void(GRT::MatrixDouble)>	onDataReadyCallback

Protected Member Functions inherited from InputStream
vector< double >	normalize (vector< double >)

Protected Attributes inherited from InputStream
vector< string >	InputStream_labels_

onDataReadyCallback	data_ready_callback_

normalizeFunc	normalizer_

vectorNormalizeFunc	vectorNormalizer_

Protected Attributes inherited from Stream
std::atomic_bool	has_started_

Detailed Description

Listening for data inputs over a TCP socket.

Constructor & Destructor Documentation

TcpInputStream::TcpInputStream	(	int	port_num,
		int	dimension
	)

inline

int TcpInputStream::getNumInputDimensions ( )

finalvirtual

Get the number of dimensions of the data that's provided by the input stream (before it's run through the normalizer, if any).

Implements InputStream.

bool TcpInputStream::start ( )

finalvirtual

Start the stream.

Reimplemented from Stream.

void TcpInputStream::stop ( )

finalvirtual

Reimplemented from Stream.

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