Tornado IOLoop.ipynb

{
 "worksheets": [
  {
   "cells": [
    {
     "metadata": {},
     "cell_type": "code",
     "input": "import zmq\nfrom zmq.eventloop import ioloop\nfrom zmq.eventloop.zmqstream import ZMQStream\n\nfrom tornado import gen\nfrom tornado.concurrent import Future\n\nimport datetime\n\ndef recv_future(socket):\n    zmqstream = ZMQStream(socket)  # Required for ZMQ\n    future = Future()\n    def _finish(reply):\n        future.set_result(reply)\n    zmqstream.on_recv(_finish)\n    return future\n\[email protected]\ndef f():\n    i = zmq.Context.instance()\n    sock = i.socket(zmq.REQ)\n    sock.connect('tcp://localhost:9005')\n    sock.send('Ping')\n    msg = yield recv_future(sock)\n    print \"Received {}\".format(msg[0])\n    raise gen.Return(msg)\n    \ni  = ioloop.IOLoop.instance()\ndt = datetime.timedelta(seconds=4)\n\na = ioloop.PeriodicCallback(f, 2000)\na.start()",
     "prompt_number": 1,
     "outputs": [],
     "language": "python",
     "trusted": true,
     "collapsed": false
    },
    {
     "metadata": {},
     "cell_type": "code",
     "input": "a.start()",
     "prompt_number": 13,
     "outputs": [
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "Received Pong!\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      }
     ],
     "language": "python",
     "trusted": true,
     "collapsed": false
    },
    {
     "metadata": {},
     "cell_type": "code",
     "input": "a.stop()",
     "prompt_number": 14,
     "outputs": [
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\n"
      }
     ],
     "language": "python",
     "trusted": true,
     "collapsed": false
    },
    {
     "metadata": {},
     "cell_type": "code",
     "input": "5",
     "prompt_number": 2,
     "outputs": [
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "Received Pong!\n"
      },
      {
       "output_type": "pyout",
       "prompt_number": 2,
       "metadata": {},
       "text": "5"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "Received Pong!\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      },
      {
       "output_type": "stream",
       "stream": "stdout",
       "text": "\nReceived Pong!"
      }
     ],
     "language": "python",
     "trusted": true,
     "collapsed": false
    }
   ],
   "metadata": {}
  }
 ],
 "metadata": {
  "gist_id": "8cfd8a32b2b5970b1e83",
  "name": "",
  "signature": "sha256:a18c05d7a38d3deff66e2c78aa72805cc85ea40d23485b77c47f05f11451366e"
 },
 "nbformat": 3
}