У меня есть следующий код:
component = Component(
transports=[
....
])
@component.on_join
async def joined(session, details):
def onmessage(*args, **kwargs):
.....
print("subscribing")
await session.subscribe(onmessage, "topic")
....
run([component], log_level=None)
Очевидно, это выдержка, код довольно длинный. Однако это работает хорошо в 99% случаев, но иногда канал «перезаписывается», ie, я вижу (после того, как несколько сообщений были правильно обработаны) сообщение «подписка» во второй раз, и сообщения принимаются дважды.
Я действительно не понимаю, почему - и был бы признателен за любую помощь! J.