rad.services.pubsub.Subscriber Class Reference

Subscriber is a protobuf-aware subscriber and uses ZmqSubscriber for the lower level protocol. More...

Public Member Functions
def	__init__
def	is_closed
	Returns true if subscriber is not running, false otherwise. More...
def	start
	Start reading from socket. More...
def	stop
	Stop reading from socket. More...
def	connect
	Connect to endpoint. More...
def	disconnect
	Disconnect from endpoint. More...
def	subscribe
	Subscribe on the topic topic_name. More...
def	unsubscribe
	Unsubscribe to topic identified by topic_name. More...
def	__init__
def	is_closed
	Returns true if subscriber is not running, false otherwise. More...
def	start
	Start reading from socket. More...
def	stop
	Stop reading from socket. More...
def	connect
	Connect to endpoint. More...
def	disconnect
	Disconnect from endpoint. More...
def	subscribe
	Subscribe on the topic topic_name. More...
def	unsubscribe
	Unsubscribe to topic identified by topic_name. More...

Detailed Description

Subscriber is a protobuf-aware subscriber and uses ZmqSubscriber for the lower level protocol.

Constructor & Destructor Documentation

def rad.services.pubsub.Subscriber.__init__	(		self,
			handler,
			topic_types
	)

def rad.services.pubsub.Subscriber.__init__	(		self,
			handler,
			topic_types
	)

Member Function Documentation

def rad.services.pubsub.Subscriber.connect	(		self,
			endpoint
	)

Connect to endpoint.

def rad.services.pubsub.Subscriber.connect	(		self,
			endpoint
	)

Connect to endpoint.

def rad.services.pubsub.Subscriber.disconnect	(		self,
			endpoint
	)

Disconnect from endpoint.

def rad.services.pubsub.Subscriber.disconnect	(		self,
			endpoint
	)

Disconnect from endpoint.

def rad.services.pubsub.Subscriber.is_closed	(		self,
			bool
	)

Returns true if subscriber is not running, false otherwise.

def rad.services.pubsub.Subscriber.is_closed	(		self,
			bool
	)

Returns true if subscriber is not running, false otherwise.

def rad.services.pubsub.Subscriber.start

(

self

)

Start reading from socket.

Todo:

: Return future instead?

Returns

Coroutine. The ZMQ socket reader coro that needs to be awaited on.

def rad.services.pubsub.Subscriber.start

(

self

)

Start reading from socket.

Todo:

: Return future instead?

Returns

Coroutine. The ZMQ socket reader coro that needs to be awaited on.

def rad.services.pubsub.Subscriber.stop

(

self

)

Stop reading from socket.

Todo:

: Return future instead?

Returns

Coroutine. The ZMQ socket reader coro that needs to be awaited on.

def rad.services.pubsub.Subscriber.stop

(

self

)

Stop reading from socket.

Todo:

: Return future instead?

Returns

Coroutine. The ZMQ socket reader coro that needs to be awaited on.

def rad.services.pubsub.Subscriber.subscribe	(		self,
			topic_name
	)

Subscribe on the topic topic_name.

Note

ZMQ topic filtering is done simply on the start of the string, subscribing to 'foo' will match the published topic 'foobar'.

Params

topic_name Topic name (str or bytes).

def rad.services.pubsub.Subscriber.subscribe	(		self,
			topic_name
	)

Subscribe on the topic topic_name.

Note

ZMQ topic filtering is done simply on the start of the string, subscribing to 'foo' will match the published topic 'foobar'.

Params

topic_name Topic name (str or bytes).

def rad.services.pubsub.Subscriber.unsubscribe	(		self,
			topic_name
	)

Unsubscribe to topic identified by topic_name.

def rad.services.pubsub.Subscriber.unsubscribe	(		self,
			topic_name
	)

Unsubscribe to topic identified by topic_name.

---

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

• INTROOT/lib/python3.7/site-packages/rad/services/pubsub.py
• rad/py/rad/src/rad/services/pubsub.py