Merge pull request #5 from me2go/master

Remove topic
vardius · Jun 30, 2020 · 48159e4 · 48159e4
2 parents 6f31ddd + 9e981f1
commit 48159e4
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/bus.go b/bus.go
@@ -84,7 +84,11 @@ func (b *messageBus) Unsubscribe(topic string, fn interface{}) error {
 			if h.callback == rv {
 				close(h.queue)
 
-				b.handlers[topic] = append(b.handlers[topic][:i], b.handlers[topic][i+1:]...)
+				if len(b.handlers[topic]) == 1 {
+					delete(b.handlers, topic)
+				} else {
+					b.handlers[topic] = append(b.handlers[topic][:i], b.handlers[topic][i+1:]...)
+				}
 			}
 		}
 

diff --git a/go.mod b/go.mod
@@ -1,3 +1,3 @@
-module github.com/vardius/message-bus
+module github.com/me2go/message-bus
 
 go 1.12