Strange behaviour (or me not properly understanding asyncio and aiozmq) - Code only sends when publish more than once

[marek-j]

The publish is only send (or received) when max > 1, but then it only sends one less time than asked to run.

 async def go():
     tb = await rpc.connect_pubsub(connect="tcp://localhost:5501")
     max = 2
     idx = 0
     while True:
        print("sleeping ")
        if idx < max:
            tb.publish("botupdates").message("Test")           
        await asyncio.sleep(4)
        idx = idx +1 
         
 
 asyncio.run(go())

[marek-j]

I go to the above example because this trivial example did not work:

 async def go():
     tb = await rpc.connect_pubsub(connect="tcp://localhost:5501")
     tb.publish("botupdates").message("Test")           
     while True:
        await asyncio.sleep(4)
        
 
 asyncio.run(go())