Fixed a bug when subscriber frames not clears after unsubscribe

qweeze / rstream

A Python asyncio-based client for RabbitMQ Streams

MIT License

84 stars 13 forks source link

Closed nesb1 closed 1 month ago

nesb1 commented 1 month ago

After unsubscribe we must clear internal queue because in next subscribe in-memory message can be a problem

nesb1 commented 1 month ago

@DanielePalaia can you release this changes?