formatting

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

examples/streams/example_with_streams.py

@@ -104,9 +104,7 @@ def main() -> None:
         message_handler=MyMessageHandler(),
         # can be first, last, next or an offset long
         # you can also specify stream filters with methods: apply_filters and filter_match_unfiltered
-        stream_consumer_options=StreamConsumerOptions(
-            offset_specification=OffsetSpecification.first
-        ),
+        stream_consumer_options=StreamConsumerOptions(offset_specification=OffsetSpecification.first),
     )
     print(
         "create a consumer and consume the test message - press control + c to terminate to consume"

rabbitmq_amqp_python_client/entities.py

@@ -148,7 +148,10 @@ class ExchangeToExchangeBindingSpecification:
     destination_exchange: str
     binding_key: Optional[str] = None
 
-
+"""
+  StreamFilterOptions defines the filtering options for a stream consumer.
+  for values and match_unfiltered see: https://www.rabbitmq.com/blog/2023/10/16/stream-filtering
+"""
 class StreamFilterOptions:
     values: Optional[list[str]] = None
     match_unfiltered: bool = False
@@ -180,7 +183,7 @@ class StreamConsumerOptions:
     Args:
         offset_specification: Either an OffsetSpecification enum value or
                                 an integer offset
-        filters: List of filter strings to apply to the stream
+        filter_options: Filter options for the stream consumer. See StreamFilterOptions
     """
 
     def __init__(