Remove unused code
This commit is contained in:
parent
016be33296
commit
0360a72f17
@ -1,35 +1,11 @@
|
|||||||
package testtools
|
package testtools
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/cyrilix/robocar-base/mqttdevice"
|
|
||||||
mqtt "github.com/eclipse/paho.mqtt.golang"
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
||||||
"github.com/golang/protobuf/proto"
|
"github.com/golang/protobuf/proto"
|
||||||
log "github.com/sirupsen/logrus"
|
log "github.com/sirupsen/logrus"
|
||||||
"sync"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
func NewFakePublisher() *FakePublisher {
|
|
||||||
return &FakePublisher{msg: make(map[string]mqttdevice.MqttValue)}
|
|
||||||
}
|
|
||||||
|
|
||||||
type FakePublisher struct {
|
|
||||||
muMsg sync.Mutex
|
|
||||||
msg map[string]mqttdevice.MqttValue
|
|
||||||
}
|
|
||||||
|
|
||||||
func (f *FakePublisher) Publish(topic string, payload mqttdevice.MqttValue) {
|
|
||||||
f.muMsg.Lock()
|
|
||||||
defer f.muMsg.Unlock()
|
|
||||||
f.msg[topic] = payload
|
|
||||||
}
|
|
||||||
|
|
||||||
func (f *FakePublisher) PublishedEvent(topic string) mqttdevice.MqttValue {
|
|
||||||
f.muMsg.Lock()
|
|
||||||
defer f.muMsg.Unlock()
|
|
||||||
return f.msg[topic]
|
|
||||||
}
|
|
||||||
|
|
||||||
type fakeMessage struct {
|
type fakeMessage struct {
|
||||||
qos byte
|
qos byte
|
||||||
topic string
|
topic string
|
||||||
|
Loading…
Reference in New Issue
Block a user