aboutsummaryrefslogtreecommitdiff
path: root/catbus_test.go
diff options
context:
space:
mode:
authorEthel Morgan <eth@ethulhu.co.uk>2020-06-24 23:21:32 +0100
committerEthel Morgan <eth@ethulhu.co.uk>2020-06-24 23:21:32 +0100
commite825e6820389fab7c97ae3665155401124ab8ecf (patch)
treef8b15365e51b2f0c8de73215ac5fb5ab14cecdb0 /catbus_test.go
parent9ccb33b03d4d2ac71fe0f1fec1ee0a64cca157f5 (diff)
make Client an interface, make Message a plain structv0.0.3
Diffstat (limited to 'catbus_test.go')
-rw-r--r--catbus_test.go4
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)