diff options
Diffstat (limited to 'pygerrit/stream.py')
| -rw-r--r-- | pygerrit/stream.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/pygerrit/stream.py b/pygerrit/stream.py index 3ca324b..86ae5b7 100644 --- a/pygerrit/stream.py +++ b/pygerrit/stream.py @@ -73,19 +73,19 @@ class GerritStream(Thread): result = self._ssh_client.run_gerrit_command("stream-events") except GerritError as e: self._error_event(e) - - poller = poll() - stdout = result.stdout - poller.register(stdout.channel) - while not self._stop.is_set(): - data = poller.poll() - for (handle, event) in data: - if handle == stdout.channel.fileno() and event == POLLIN: - try: - line = stdout.readline() - json_data = json.loads(line) - self._gerrit.put_event(json_data) - except (ValueError, IOError) as err: - self._error_event(err) - except GerritError as err: - logging.error("Failed to put event: %s", err) + else: + poller = poll() + stdout = result.stdout + poller.register(stdout.channel) + while not self._stop.is_set(): + data = poller.poll() + for (handle, event) in data: + if handle == stdout.channel.fileno() and event == POLLIN: + try: + line = stdout.readline() + json_data = json.loads(line) + self._gerrit.put_event(json_data) + except (ValueError, IOError) as err: + self._error_event(err) + except GerritError as err: + logging.error("Failed to put event: %s", err) |