Feature/ab#2319 implement backpressure

[flonix8]

Description

This PR adds backpressure, which effectively enables the Valkey stream to be used as a queue with a blocking write operation. This change makes it possible to operate bottleneck components (e.g. object-detector) at their maximum throughput without losing messages.
The implementation is fully compatible with older versions.

Motivation and Context

How has this been tested?

There are new tests covering different usage scenarios.

Screenshots (if appropriate):

Types of changes

• Bug fix (non-breaking change which fixes an issue)
• New feature (non-breaking change which adds functionality)
• Breaking change (fix or feature that would cause existing functionality to not work as expected)

Checklist:

• My code follows the code style of this project.
• My change requires a change to the documentation.
• I have updated the documentation accordingly.