Skip to content

Commit c960942

Browse files
authored
fix: correctly set 'since' on one off follower (#734)
1 parent bd0c946 commit c960942

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

ibmcloudant/features/changes_follower.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,6 @@ def __init__(
107107
self._limit = None
108108
self._stop = Event()
109109
self.logger = logging.getLogger(__name__)
110-
self._request_thread.start()
111110

112111
@property
113112
def limit(self) -> int:
@@ -127,6 +126,9 @@ def since(self) -> str:
127126
def since(self, value: str) -> None:
128127
self._since = value
129128

129+
def _start(self) -> None:
130+
self._request_thread.start()
131+
130132
def stop(self) -> None:
131133
# shortcut limit and cancel in-flight
132134
self.limit = 0
@@ -454,4 +456,5 @@ def _run(self, mode: _Mode):
454456
self._iter.limit = self.limit
455457
if self.options.get('since') is not None:
456458
self._iter.since = self.options.get('since')
459+
self._iter._start()
457460
return self._iter

0 commit comments

Comments
 (0)