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 18d6284 commit c60580bCopy full SHA for c60580b
logstash_async/transport.py
@@ -145,7 +145,7 @@ def _wait_for_socket_buffer_empty(self):
145
time_waited = 0
146
# wait until the socket's write buffer is empty
147
# but do not wait longer than SOCKET_CLOSE_WAIT_TIMEOUT
148
- while not self._is_sock_write_buff_empty() and time_waited < wait_timeout:
+ while time_waited < wait_timeout and not self._is_sock_write_buff_empty():
149
time_waited += interval
150
time.sleep(interval)
151
0 commit comments