Public Member Functions
def	__init__

def	is_closed
	Returns true if the socket is closed, true otherwise. More...

def	start
	Start reading from socket. More...

def	send
	Send `msg` with name `msg_name` to `identity`. More...

def	stop
	Unbinds socket and shuts down all related tasks to this Replier. More...

def	__init__

def	is_closed
	Returns true if the socket is closed, true otherwise. More...

def	start
	Start reading from socket. More...

def	send
	Send `msg` with name `msg_name` to `identity`. More...

def	stop
	Unbinds socket and shuts down all related tasks to this Replier. More...

Constructor & Destructor Documentation

def rad.services.msg.ZmqMsgReplier.__init__	(	self,
		endpoint
	)

def rad.services.msg.ZmqMsgReplier.__init__	(	self,
		endpoint
	)

Member Function Documentation

def rad.services.msg.ZmqMsgReplier.is_closed	(	self,
		bool
	)

Returns true if the socket is closed, true otherwise.

def rad.services.msg.ZmqMsgReplier.is_closed	(	self,
		bool
	)

Returns true if the socket is closed, true otherwise.

def rad.services.msg.ZmqMsgReplier.send	(	self,
		identity
	)

Send msg with name msg_name to identity.

RuntimeError if socket is closed.

def rad.services.msg.ZmqMsgReplier.send	(	self,
		identity
	)

Send msg with name msg_name to identity.

RuntimeError if socket is closed.

def rad.services.msg.ZmqMsgReplier.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.msg.ZmqMsgReplier.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.msg.ZmqMsgReplier.stop ( self )

Unbinds socket and shuts down all related tasks to this Replier.

    The ZmqMsgReplier is essentially dead after this.

Returns: Future that resolves once server has been closed.

Examples

>> import zmq >> import asyncio >> loop = asyncio.new_event_loop() >> def handler(identity, msg_name, msg): .. pass >> replier = ZmqMsgReplier(msg_handler=handler, .. endpoint='inproc://foobar', zmq_ctx=zmq.asyncio.Context(), loop=loop) >> fut = replier.stop() >> loop.run_until_complete(asyncio.wait_for(fut, 2)) >> loop.close()