Избавиться от deque delayed_stream_messages в пользу обычного счётчика
gitlab.dvmn.org/…/fastapi_proxy.py#L279-295
async def delay(delay_time: float, payload):
delayed_stream_messages.append(payload)
try:
await sleep(delay_time)
await common_sender_queue_input.send(payload)
finally:
delayed_stream_messages.remove(payload)
На самом деле, нам не важно содержимое delayed_stream_messages. Нужен только счётчик -- чиселка.