Updating messages iterator

quartiq · Jul 1, 2024 · e0fd984 · e0fd984
1 parent f2647b2
commit e0fd984
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/aiomqtt/client.py b/aiomqtt/client.py
@@ -238,7 +238,6 @@ def __init__(  # noqa: C901, PLR0912, PLR0913, PLR0915
         if max_queued_incoming_messages is None:
             max_queued_incoming_messages = 0
         self._queue = queue_type(maxsize=max_queued_incoming_messages)
-        self.messages = self._messages()
 
         # Semaphore to limit the number of concurrent outgoing calls
         self._outgoing_calls_sem: asyncio.Semaphore | None
@@ -321,6 +320,10 @@ def __init__(  # noqa: C901, PLR0912, PLR0913, PLR0915
             timeout = 10
         self.timeout = timeout
 
+    @property
+    def messages(self) -> AsyncGenerator[Message, None]:
+        return self._messages()
+
     @property
     def identifier(self) -> str:
         """Return the client identifier.