Feature: subscriber iteration support #1881
Labels
Core
Issues related to core FastStream functionality and affects to all brokers
enhancement
New feature or request
help wanted
Extra attention is needed
We should support alternative way to consume messages instead of decorator callbacks
I think, iteration should be impelemnet something like this
This functional is pretty close to
subscriber.get_one()
already exists - https://github.com/airtai/faststream/blob/main/faststream/broker/subscriber/proto.py#L90Also, implementation should be close to this method as well - https://github.com/airtai/faststream/blob/main/faststream/nats/subscriber/usecase.py#L369 , but use native underlying libraries iterations everywhere it is possible
The text was updated successfully, but these errors were encountered: