expand example to demonstrate deregister

examples/observer/observer.go

@@ -7,20 +7,32 @@ import (
 	"github.com/onyx-and-iris/voicemeeter-api-go/voicemeeter"
 )
 
-type observer struct{}
+type observer struct {
+	i int
+}
 
 func (o observer) OnUpdate(subject string) {
-	fmt.Println(subject)
+	fmt.Println(o.i, subject)
 }
 
 func main() {
 	vmRem := voicemeeter.GetRemote("banana")
 	vmRem.Login()
 
-	o := observer{}
+	o := observer{1}
-	vmRem.Pooler.Publisher.Register(o)
+	o2 := observer{2}
+	o3 := observer{3}
+	o4 := observer{4}
+	vmRem.Pooler.Register(o)
+	vmRem.Pooler.Register(o2)
+	vmRem.Pooler.Register(o3)
+	vmRem.Pooler.Register(o4)
 
-	time.Sleep(10 * time.Second)
+	time.Sleep(5 * time.Second)
+
+	vmRem.Pooler.Deregister(o2)
+
+	time.Sleep(5 * time.Second)
 
 	vmRem.Logout()
 }

voicemeeter/publisher.go

@@ -47,10 +47,10 @@ func newPooler() *Pooler {
 func (r *Pooler) runner() {
 	for r.run {
 		if pdirty() {
-			r.Publisher.notify("pdirty")
+			r.notify("pdirty")
 		}
 		if mdirty() {
-			r.Publisher.notify("mdirty")
+			r.notify("mdirty")
 		}
 	}
 }