feat: add __aiter__ method in SubscriberProto

airtai · Jan 28, 2025 · ab10944 · ab10944
1 parent 4fc7dc3
commit ab10944
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/faststream/_internal/subscriber/proto.py b/faststream/_internal/subscriber/proto.py
@@ -91,3 +91,7 @@ def add_call(
         middlewares_: Sequence["SubscriberMiddleware[Any]"],
         dependencies_: Iterable["Dependant"],
     ) -> Self: ...
+
+    @abstractmethod
+    def __aiter__(self) -> StreamMessage[MsgType]:
+        ...