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.

def stop_subscribe(self):
        """ 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.

        """
        asyncio.gather(*asyncio.Task.all_tasks()).cancel()
        self.event_loop.stop()
        self.event_loop.close()