From 21b02b2519cecb763d05e73fbbd3282edf8126f9 Mon Sep 17 00:00:00 2001 From: leonsteinhaeuser Date: Wed, 13 Apr 2022 19:06:27 +0200 Subject: [PATCH] docs: simplified example --- README.md | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/README.md b/README.md index ff4767c..9e0a74c 100644 --- a/README.md +++ b/README.md @@ -19,25 +19,28 @@ import ( ) type Event struct { - ID int + ID int Message string } var ( - obsrv observer.Observable[int, Event] = observer.NewObserver[int, Event]() + obsrv observer.Observable[Event] = observer.NewObserver[Event]() ) func main() { - obsrv.RegisterClient(1, make(chan Event)) + rspCh, cancelFunc := obsrv.Subscribe() + defer cancelFunc() + go func() { + for { + fmt.Printf("Received event: %v\n", <-rspCh) + } + }() + fmt.Println("Registered Clients: ", obsrv.Clients()) + obsrv.NotifyAll(Event{ ID: i, - Message: fmt.Sprintf("Message with ID %d", i), + Message: "Hello World", }) - fmt.Println("Registered Clients: ", obsrv.Clients()) - err := obsrv.DeRegisterClient(1) - if err != nil { - fmt.Println(err) - } } ```