diff options
Diffstat (limited to '')
| -rw-r--r-- | catbus_test.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/catbus_test.go b/catbus_test.go index cc22ebb..b345c48 100644 --- a/catbus_test.go +++ b/catbus_test.go @@ -105,7 +105,7 @@ func TestOnConnect(t *testing.T) { payloadByTopic: map[string]string{}, } - catbus := &Client{ + catbus := &client{ mqtt: fakeMQTT, payloadByTopic: map[string]string{}, onconnectTimerByTopic: map[string]*time.Timer{}, @@ -117,7 +117,7 @@ func TestOnConnect(t *testing.T) { } for _, topic := range tt.subscribe { - catbus.Subscribe(topic, func(_ *Client, _ Message) {}) + catbus.Subscribe(topic, func(_ Client, _ Message) {}) } for topic, message := range tt.receive { fakeMQTT.send(topic, message.retention, message.payload) |