code: def subscribe_async(self, subject, **kwargs):
          
          kwargs["is_async"] = True
          sid = yield self.subscribe(subject, **kwargs)
          raise tornado.gen.Return(sid)
docs: Schedules callback from subscription to be processed asynchronously
          in the next iteration of the loop.