Method subscribe

tests/integration/conftest.py:203–207

(self, topic: str, qos: int = 0)

            self.messages = received

        def subscribe(self, topic: str, qos: int = 0) -> None:
            self.client.subscribe(topic, qos)
            # Give the broker a moment to register the subscription so
            # subsequent publishes are delivered.
            time.sleep(0.2)

        def wait_for_messages(self, count: int = 1, timeout: float = 5.0) -> bool:
            end = time.time() + timeout