@gen.coroutine
def sender():
 tic = time.time()
 push = ctx.socket(zmq.PUSH)
 push.bind(url)
 poller = Poller()
 poller.register(push, zmq.POLLOUT)
 while True:
  print 'sending'
  (yield push.send_multipart([str((time.time() - tic)).encode('ascii')]))
  (yield gen.sleep(1))

@ gen . coroutine def sender ( ) : tic = time . time ( ) push = ctx . socket ( zmq . PUSH ) push . bind ( url ) poller = Poller ( ) poller . register ( push , zmq . POLLOUT ) while True : print 'sending' ( yield push . send_multipart ( [ str ( ( time . time ( ) - tic ) ) . encode ( 'ascii' ) ] ) ) ( yield gen . sleep ( 1 ) )
send a message every second .