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 } }