Package rospy :: Package impl :: Module tcpros_pubsub

Module tcpros_pubsub

source code

Internal use: Topic-specific extensions for TCPROS support

Classes
  TCPROSSub
Subscription transport implementation for receiving topic data via peer-to-peer TCP/IP sockets
  TCPROSPub
Publisher transport implementation for publishing topic data via peer-to-peer TCP/IP sockets.
  TCPROSHandler
ROS Protocol handler for TCPROS.
  QueuedConnection
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.
Functions
 
robust_connect_subscriber(conn, dest_addr, dest_port, pub_uri, receive_cb, resolved_topic_name)
Keeps trying to create connection for subscriber.
source code
 
check_if_still_publisher(resolved_topic_name, pub_uri) source code
Variables
  __package__ = 'rospy.impl'
Function Details

robust_connect_subscriber(conn, dest_addr, dest_port, pub_uri, receive_cb, resolved_topic_name)

source code 

Keeps trying to create connection for subscriber. Then passes off to receive_loop once connected.