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 0855f76 commit 5d1e254Copy full SHA for 5d1e254
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