We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1407550 commit 57f6071Copy full SHA for 57f6071
ibmcloudant/features/changes_follower.py
@@ -157,7 +157,9 @@ def __next__(self):
157
raise StopIteration from exc
158
if isinstance(data, Exception):
159
raise data from None
160
- self._changes_iter = iter(data)
+ self._changes_iter = iter(
161
+ (ChangesResultItem.from_dict(item) for item in data)
162
+ )
163
self._buffer.task_done()
164
165
def _request_callback(self):
@@ -178,9 +180,7 @@ def _request_callback(self):
178
180
self._buffer.join()
179
181
if self._stop.is_set():
182
raise StopIteration
- self._buffer.put(
- [ChangesResultItem.from_dict(item) for item in results]
183
- )
+ self._buffer.put(results)
184
except Exception as e:
185
self.logger.debug(f'Exception getting changes {e}')
186
if (
0 commit comments