We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a2b3d5d commit fc8a31bCopy full SHA for fc8a31b
1 file changed
kubernetes/client/ws_client.py
@@ -168,11 +168,13 @@ def update(self, timeout=0):
168
data = frame.data
169
if six.PY3:
170
data = data.decode("utf-8")
171
- self._all += data
172
if len(data) > 1:
173
channel = ord(data[0])
174
data = data[1:]
175
if data:
+ # keeping all messages in the order they received for
176
+ # non-blocking call.
177
+ self._all += data
178
if channel not in self._channels:
179
self._channels[channel] = data
180
else:
0 commit comments