Welcome to mirror list, hosted at ThFree Co, Russian Federation.

dev.gajim.org/gajim/python-nbxmpp.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorlovetox <philipp@hoerist.com>2020-03-28 10:08:57 +0300
committerlovetox <philipp@hoerist.com>2020-03-28 10:08:57 +0300
commit80ec5753de06bc8e92dd49b2aec4f8b13ec8401d (patch)
tree9047532b000a3db8d6b0828fcf0c2cb756d8fb82
parentb0038b2833e70b4df191cbbcd832e7c0f2aae9bf (diff)
TCP: Initiate new read before data-received signal
-rw-r--r--nbxmpp/tcp.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/nbxmpp/tcp.py b/nbxmpp/tcp.py
index be00732..f50db27 100644
--- a/nbxmpp/tcp.py
+++ b/nbxmpp/tcp.py
@@ -236,13 +236,13 @@ class TCPConnection(Connection):
self._log_stanza(data, received=True)
+ self._read_async()
+
try:
self.notify('data-received', data)
except Exception:
self._log.exception('Error while executing data-received:')
- self._read_async()
-
def _write_stanzas(self):
self._write_stanza_buffer = self._write_queue
self._write_queue = deque([])