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.
2 parents 806fb62 + fd13fc8 commit f81c728Copy full SHA for f81c728
kubernetes/base/stream/ws_client.py
@@ -182,6 +182,8 @@ def update(self, timeout=0):
182
if hasattr(select, "poll"):
183
poll = select.poll()
184
poll.register(self.sock.sock, select.POLLIN)
185
+ if timeout is not None:
186
+ timeout *= 1_000 # poll method uses milliseconds as the time unit
187
r = poll.poll(timeout)
188
poll.unregister(self.sock.sock)
189
else:
0 commit comments