zmq::ypipe_conflate_t< T > Class Template Reference

#include <ypipe_conflate.hpp>

Inheritance diagram for zmq::ypipe_conflate_t< T >:

Collaboration diagram for zmq::ypipe_conflate_t< T >:

Public Member Functions
	ypipe_conflate_t ()
virtual	~ypipe_conflate_t ()
bool	check_read ()
bool	flush ()
bool	probe (bool(*fn)(const T &))
bool	read (T *value_)
bool	unwrite (T *)
void	write (const T &value_, bool incomplete_)
Public Member Functions inherited from zmq::ypipe_base_t< T >
virtual	~ypipe_base_t ()

Protected Member Functions
	ypipe_conflate_t (const ypipe_conflate_t &)
const ypipe_conflate_t &	operator= (const ypipe_conflate_t &)

Protected Attributes
dbuffer_t< T >	dbuffer
bool	reader_awake

Detailed Description

template<typename T>
class zmq::ypipe_conflate_t< T >

Definition at line 47 of file ypipe_conflate.hpp.

Constructor & Destructor Documentation

template<typename T >

zmq::ypipe_conflate_t< T >::ypipe_conflate_t ( )

inline

Definition at line 52 of file ypipe_conflate.hpp.

template<typename T >

virtual zmq::ypipe_conflate_t< T >::~ypipe_conflate_t ( )

inlinevirtual

Definition at line 59 of file ypipe_conflate.hpp.

template<typename T >

zmq::ypipe_conflate_t< T >::ypipe_conflate_t ( const ypipe_conflate_t< T > &  )

protected

Member Function Documentation

template<typename T >

bool zmq::ypipe_conflate_t< T >::check_read ( )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 98 of file ypipe_conflate.hpp.

References zmq::ypipe_conflate_t< T >::dbuffer, and zmq::ypipe_conflate_t< T >::reader_awake.

Referenced by zmq::ypipe_conflate_t< T >::read().

Here is the caller graph for this function:

template<typename T >

bool zmq::ypipe_conflate_t< T >::flush ( )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 92 of file ypipe_conflate.hpp.

References zmq::ypipe_conflate_t< T >::reader_awake.

template<typename T >

const ypipe_conflate_t& zmq::ypipe_conflate_t< T >::operator= ( const ypipe_conflate_t< T > &  )

protected

template<typename T >

bool zmq::ypipe_conflate_t< T >::probe ( bool(*)(const T &)  fn )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 120 of file ypipe_conflate.hpp.

References zmq::ypipe_conflate_t< T >::dbuffer.

template<typename T >

bool zmq::ypipe_conflate_t< T >::read ( T *  value_ )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 109 of file ypipe_conflate.hpp.

References zmq::ypipe_conflate_t< T >::check_read(), and zmq::ypipe_conflate_t< T >::dbuffer.

Here is the call graph for this function:

template<typename T >

bool zmq::ypipe_conflate_t< T >::unwrite ( T *  )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 83 of file ypipe_conflate.hpp.

template<typename T >

void zmq::ypipe_conflate_t< T >::write ( const T &  value_, bool  incomplete_  )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 71 of file ypipe_conflate.hpp.

References zmq::ypipe_conflate_t< T >::dbuffer.

Member Data Documentation

template<typename T >

dbuffer_t<T> zmq::ypipe_conflate_t< T >::dbuffer

protected

Definition at line 127 of file ypipe_conflate.hpp.

Referenced by zmq::ypipe_conflate_t< T >::check_read(), zmq::ypipe_conflate_t< T >::probe(), zmq::ypipe_conflate_t< T >::read(), and zmq::ypipe_conflate_t< T >::write().

template<typename T >

bool zmq::ypipe_conflate_t< T >::reader_awake

protected

Definition at line 128 of file ypipe_conflate.hpp.

Referenced by zmq::ypipe_conflate_t< T >::check_read(), and zmq::ypipe_conflate_t< T >::flush().