Open
Description
Describe the bug
Redis broker does not process message with decode_responses=True param
How to reproduce
Include source code:
from faststream.redis import RedisBroker
broker = RedisBroker(
url=str(config.REDIS_DSN),
logger=logger,
max_connections=20,
decode_responses=True,
)
sub_config = StreamSub(
stream='test',
group='test',
consumer='test'
)
@broker.subscriber(stream=sub_config)
async def test():
print('hello')