niryo_libraries.rospy.impl.tcpros_pubsub.QueuedConnection

class documentation

class QueuedConnection(object):

Constructor: QueuedConnection(connection, queue_size)

It wraps a Transport instance and behaves like one but it queues the data written to it and relays them asynchronously to the wrapped instance.

Method	`__getattr__`	Undocumented
Method	`__init__`	ctor. @param connection: the wrapped transport instance @type connection: Transport @param queue_size: the maximum size of the queue, zero means infinite @type queue_size: int
Method	`write_data`	Undocumented
Method	`_closed_connection_callback`	Undocumented
Method	`_run`	Undocumented
Instance Variable	`_cond_data_available`	Undocumented
Instance Variable	`_connection`	Undocumented
Instance Variable	`_error`	Undocumented
Instance Variable	`_lock`	Undocumented
Instance Variable	`_queue`	Undocumented
Instance Variable	`_queue_size`	Undocumented
Instance Variable	`_thread`	Undocumented

def __getattr__(self, name): ¶

Undocumented

def __init__(self, connection, queue_size): ¶

ctor. @param connection: the wrapped transport instance @type connection: Transport @param queue_size: the maximum size of the queue, zero means infinite @type queue_size: int

def write_data(self, data): ¶

Undocumented

def _closed_connection_callback(self, connection): ¶

Undocumented

def _run(self): ¶

Undocumented

_cond_data_available = ¶

Undocumented

_connection = ¶

Undocumented

_error = ¶

Undocumented

_lock = ¶

Undocumented

_queue: list = ¶

Undocumented

_queue_size = ¶

Undocumented

_thread = ¶

Undocumented