code: def stop_subscribe(self):
          
          asyncio.gather(*asyncio.Task.all_tasks()).cancel()
          self.event_loop.stop()
          self.event_loop.close()
docs: This function is used to stop the event loop created when subscribe is called. But this function doesn't
          stop the thread and should be avoided until its completely developed.