aio-libs / aiozmq

Asyncio (pep 3156) integration with ZeroMQ
aiozmq.readthedocs.org
BSD 2-Clause "Simplified" License
422 stars 56 forks source link

Receiver end stops receiving #155

Open JoseKilo opened 5 years ago

JoseKilo commented 5 years ago

I have a minimal example code in this gist https://gist.github.com/JoseKilo/319493e6ef3f17d86a76ad7c7b20055e

It's a modified version of the stream-dealer-router example https://github.com/aio-libs/aiozmq/blob/master/examples/stream_dealer_router.py

The differences are:

When both are launched, they start working as expected, but after some time, the sender keeps iterating and the receiver stops receiving.

When the reply message is enabled, the problem disappears, but the communication is also slower.

Depending on which process is started first, the problem appears sooner or later.