

def _rtm_read_forever(self):
    while True:
        json_data = self._websocket_safe_read()
        if (json_data != ''):
            with self._events_lock:
                self.events.extend([json.loads(d) for d in json_data.split('\n')])
        time.sleep(1)

dataset/ETHPy150Open lins05/slackbot/tests/functional/driver.py Driver._rtm_read_forever/original