From 49c35a2d56db595e2713745d772e119cd90f07de Mon Sep 17 00:00:00 2001 From: andig Date: Sun, 24 Dec 2023 13:53:32 +0100 Subject: [PATCH] Revert "Mqtt: wait for retained messages" This reverts commit 96ef894ccce60aab0b20a40186542ba4e8bbf29e. --- provider/mqtt/client.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/provider/mqtt/client.go b/provider/mqtt/client.go index 2aeb7568e..e59324643 100644 --- a/provider/mqtt/client.go +++ b/provider/mqtt/client.go @@ -141,8 +141,6 @@ func (m *Client) Listen(topic string, callback func(string)) error { case <-time.After(request.Timeout): return fmt.Errorf("subscribe: %s: %w", topic, api.ErrTimeout) case <-token.Done(): - // TODO depends on https://github.com/eclipse/paho.mqtt.golang/issues/663 - time.Sleep(100 * time.Millisecond) return nil } }