gistfile1.txt

def recv_future(zmqstream):
    ''' Retruns future for recv on zmqstream
    '''

    future = Future()

    def _finish(reply):
        future.set_result(reply)
    zmqstream.on_recv(_finish)
    return future


def poll_sync():
    context = zmq.Context().instance()
    socket = context.socket(zmq.REQ)
    socket.connect("tcp://localhost:9802")
    socket.send('Ping'.encode('utf-8'))
    result = socket.recv()
    socket.close()
    return result


@gen.coroutine
def poll_async():
    context = zmq.Context().instance()
    socket = context.socket(zmq.REQ)
    socket.connect("tcp://localhost:9802")
    zmqstream = ZMQStream(socket)  # Required for ZMQ
    zmqstream.send('Ping'.encode('utf-8'))
    result = yield recv_future(zmqstream)
    zmqstream.close()
    raise gen.Return(result[0])