fix: Recreate group in case redis flush

 - fixing group creation in autoclaim + get_one message and iter.

Author: pbonneaudiabolocom

faststream/redis/subscriber/usecases/stream_subscriber.py

@@ -219,7 +219,7 @@ def read(
 
         await super().start(read)
 
-    async def _get_one_message(self, timeout: float) -> None:
+    async def _get_one_message(self, timeout: float) -> Optional[ReadResponse]:
         if self.stream_sub.group and self.stream_sub.consumer:
             def _readgroup_call() -> Awaitable[ReadResponse]:
                 return self._client.xreadgroup(
@@ -274,6 +274,8 @@ def _autoclaim_call() -> Awaitable[Any]:
                 stream=self.stream_sub,
             )
             stream_message = await protected_autoclaim()
+            if not stream_message:
+                return None
 
             (next_id, messages, _) = stream_message
             # Update start_id for next call