add async iterator

Author: Toubat

python/convex/__init__.py

@@ -120,6 +120,15 @@ def __next__(self) -> ConvexValue:
             raise ConvexError(result["message"], result["data"])
         return result["value"]
 
+    def __aiter__(self) -> QuerySubscription:
+        return self
+
+    async def __anext__(self) -> ConvexValue:
+        result = await self.safe_inner_sub().anext()
+        if result["type"] == "convexerror":
+            raise ConvexError(result["message"], result["data"])
+        return result["value"]
+
     def unsubscribe(self) -> None:
         """Unsubscribe from the query and drop this subscription from the active query set.
 
@@ -162,6 +171,17 @@ def __next__(self) -> Optional[Dict[SubscriberId, ConvexValue]]:
             result[k] = result[k]
         return result
 
+    def __aiter__(self) -> QuerySetSubscription:
+        return self
+
+    async def __anext__(self) -> Optional[Dict[SubscriberId, ConvexValue]]:
+        result = await self.safe_inner_sub().anext()
+        if not result:
+            return result
+        for k in result:
+            result[k] = result[k]
+        return result
+
 
 class ConvexClient:
     """WebSocket-based Convex Client.