def start(self):
        queries = dict((k,v) for (k,v) in [(k,self.handler) for k in self.queries])
        if len(queries)>0: 
            self.connection.subscribe(**queries)
            self._thread = self.connection.run_in_thread(sleep_time=0.001)
        else:
            self._thread = None
dataset/ETHPy150Open rwalk333/straw/src/frontend/app/query_subscriber.py/QuerySubscriber.start/original