KrumBoychev

The following code generate SlowConsumerError even the pending queue is empty: ```python import asyncio import nats from nats.errors import TimeoutError async def main(): errors = [] async def error_cb(err): errors.append(err)...