xmlstream: fix use of the waiting queue

This commit is contained in:
mathieui 2021-04-22 21:07:30 +02:00
parent 3630c3d1cc
commit a4789acbfb

View file

@ -1146,7 +1146,7 @@ class XMLStream(asyncio.BaseProtocol):
or isinstance(data, Handshake) or isinstance(data, Handshake)
) )
if isinstance(data, (RootStanza, str)) and not passthrough: if isinstance(data, (RootStanza, str)) and not passthrough:
self.__queued_stanzas.append(data) self.__queued_stanzas.append((data, use_filters))
log.debug('NOT SENT: %s %s', type(data), data) log.debug('NOT SENT: %s %s', type(data), data)
return return
self.waiting_queue.put_nowait((data, use_filters)) self.waiting_queue.put_nowait((data, use_filters))