Skip to content

Commit

Permalink
docs: simplified example
Browse files Browse the repository at this point in the history
  • Loading branch information
leonsteinhaeuser committed Apr 13, 2022
1 parent 5c605ec commit 21b02b2
Showing 1 changed file with 12 additions and 9 deletions.
21 changes: 12 additions & 9 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
}
```

Expand Down

0 comments on commit 21b02b2

Please sign in to comment.