code: def _reconnect_cb(self):
          
          @asyncio.coroutine
          def try_reconnect():
              """Actual coroutine ro try to reconnect or reschedule."""
              try:
                  yield from self._do_connect()
              except IOError:
                  self._loop.call_later(SERVER_RECONNECT_DELAY,
                                        self._reconnect_cb)
          asyncio.ensure_future(try_reconnect())
docs: Callback to reconnect to the server.