qweeze / rstream

A Python asyncio-based client for RabbitMQ Streams
MIT License
83 stars 13 forks source link

Metadata update #166

Closed DanielePalaia closed 10 months ago

DanielePalaia commented 10 months ago

This closes #113

An attempt to manage MetadataUpdate.

The approach is similar on how we manage disconnection.

The client is notified that a MetadataUpdate occoured through a callback.

As the approach is similar to the disconnection scenario we are re-using the same callback. The name of the callback as been rewritten as on_close_handler and the dataclass that is returning the info has been renamed to OnClosedErrorInfo

Examples have been provided but this is still missing system-tests.