diff options
author | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-24 23:21:32 +0100 |
---|---|---|
committer | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-24 23:21:32 +0100 |
commit | e825e6820389fab7c97ae3665155401124ab8ecf (patch) | |
tree | f8b15365e51b2f0c8de73215ac5fb5ab14cecdb0 /catbus_test.go | |
parent | 9ccb33b03d4d2ac71fe0f1fec1ee0a64cca157f5 (diff) |
make Client an interface, make Message a plain structv0.0.3
Diffstat (limited to 'catbus_test.go')
-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) |