niryo_libraries.rospy.impl.tcpros_pubsub.TCPROSSub

class documentation

class TCPROSSub(TCPROSTransportProtocol):

Constructor: TCPROSSub(resolved_name, recv_data_class, queue_size, buff_size, tcp_nodelay)

View In Hierarchy

Subscription transport implementation for receiving topic data via peer-to-peer TCP/IP sockets

Method __init__ ctor.
Method get_header_fields @return: dictionary of subscriber fields @rtype: dict
Instance Variable direction Undocumented
Instance Variable tcp_nodelay Undocumented
def __init__(self, resolved_name, recv_data_class, queue_size=None, buff_size=DEFAULT_BUFF_SIZE, tcp_nodelay=False):

ctor.

@param resolved_name: resolved subscription name @type resolved_name: str

@param recv_data_class: class to instantiate to receive messages @type recv_data_class: L{rospy.Message}

@param queue_size: maximum number of messages to deserialize from newly read data off socket @type queue_size: int

@param buff_size: recv buffer size @type buff_size: int

@param tcp_nodelay: If True, request TCP_NODELAY from publisher @type tcp_nodelay: bool

def get_header_fields(self):

@return: dictionary of subscriber fields @rtype: dict

direction =

Undocumented

tcp_nodelay =

Undocumented