modify drivers
This commit is contained in:
@@ -4,20 +4,26 @@ import "slices"
|
||||
|
||||
// topic model
|
||||
type Topic struct {
|
||||
Publish []string `json:"Publish,omitemtpy"`
|
||||
Subscribe []string `json:"subscribe,omitemtpy"`
|
||||
Publish []string `json:"Publish,omitempty"`
|
||||
Subscribe []string `json:"subscribe,omitempty"`
|
||||
}
|
||||
|
||||
func (t *Topic) AddSubscription(sub string) {
|
||||
if !slices.Contains(t.Subscribe, sub) {
|
||||
func (t *Topic) AddSubscription(subs ...string) {
|
||||
for _, sub := range subs {
|
||||
if slices.Contains(t.Subscribe, sub) {
|
||||
continue
|
||||
}
|
||||
t.Subscribe = append(t.Subscribe, sub)
|
||||
slices.Sort(t.Subscribe)
|
||||
}
|
||||
}
|
||||
|
||||
func (t *Topic) AddPublish(pub string) {
|
||||
if !slices.Contains(t.Publish, pub) {
|
||||
t.Publish = append(t.Publish, pub)
|
||||
func (t *Topic) AddPublish(pubs ...string) {
|
||||
for _, pub := range pubs {
|
||||
if slices.Contains(t.Publish, pub) {
|
||||
continue
|
||||
}
|
||||
t.Subscribe = append(t.Publish, pub)
|
||||
slices.Sort(t.Publish)
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user