Rstream

Latest version: v0.20.6

Safety actively analyzes 681866 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 5 of 6

0.10.1

What's Changed

* Performance improvements when producing using `send()` (see https://github.com/qweeze/rstream/issues/84)
* Add Examples: https://github.com/qweeze/rstream/tree/master/docs/examples

0.10.0

What's Changed

* Single active consumer implementation https://github.com/qweeze/rstream/pull/79
See [the blog post]( https://blog.rabbitmq.com/posts/2022/07/rabbitmq-3-11-feature-preview-single-active-consumer-for-streams/).
You can find an example [here](https://github.com/qweeze/rstream/tree/master/docs/examples/single_active_consumer)
* Manual tracking of stream offsets (`store_offset` to store offset to the server and `query_offset` to retrieve the offset from the server ): https://github.com/qweeze/rstream/issues/65
* Removed the work-in-progress label https://github.com/qweeze/rstream/pull/76

0.9.0

What's Changed

* Server side offset manual storing is now supported: See https://github.com/qweeze/rstream/issues/65 and https://github.com/qweeze/rstream/blob/master/docs/examples/manual_server_offset_tracking/consumer.py
* Improve performance for superstream producer using cache for ROUTE and PARTITION commands.

0.8.1

What's Changed

* Fixed a bug on offset returned by consumer callback: https://github.com/qweeze/rstream/pull/71

0.8

What's Changed

* Now supports superstreams: https://github.com/qweeze/rstream/issues/58
* Improvements in consumer callbacks now returning the stream name, the offset and the timestamp of the message

0.7

What's Changed

* Now supports sub-entry batching: https://github.com/qweeze/rstream/issues/53
* Fixed a bug when multiple different on_publish_confirm callbacks are set in Send()/SendBatch() apis

Page 5 of 6

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.