diff options
author | Felix Lange <fjl@twurst.com> | 2014-10-17 00:07:27 +0800 |
---|---|---|
committer | Felix Lange <fjl@twurst.com> | 2014-10-17 00:50:48 +0800 |
commit | dac4a8f113b35c67349115115af17c7f1874d939 (patch) | |
tree | 80ca03e6b76c24323a9f0dd56f7d225ca2a4e7c4 /event/example_test.go | |
parent | f5b8775bed8a49136c5d7e93bb0fb991bc2b1a4b (diff) | |
download | go-tangerine-dac4a8f113b35c67349115115af17c7f1874d939.tar.gz go-tangerine-dac4a8f113b35c67349115115af17c7f1874d939.tar.zst go-tangerine-dac4a8f113b35c67349115115af17c7f1874d939.zip |
event: add some documentation
Diffstat (limited to 'event/example_test.go')
-rw-r--r-- | event/example_test.go | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/event/example_test.go b/event/example_test.go new file mode 100644 index 000000000..2f47f6f27 --- /dev/null +++ b/event/example_test.go @@ -0,0 +1,42 @@ +package event + +import "fmt" + +func ExampleTypeMux() { + type someEvent struct{ I int } + type otherEvent struct{ S string } + type yetAnotherEvent struct{ X, Y int } + + var mux TypeMux + + // Start a subscriber. + done := make(chan struct{}) + sub := mux.Subscribe(someEvent{}, otherEvent{}) + go func() { + for event := range sub.Chan() { + fmt.Printf("Received: %#v\n", event) + } + fmt.Println("done") + close(done) + }() + + // Post some events. + mux.Post(someEvent{5}) + mux.Post(yetAnotherEvent{X: 3, Y: 4}) + mux.Post(someEvent{6}) + mux.Post(otherEvent{"whoa"}) + + // Stop closes all subscription channels. + // The subscriber goroutine will print "done" + // and exit. + mux.Stop() + + // Wait for subscriber to return. + <-done + + // Output: + // Received: event.someEvent{I:5} + // Received: event.someEvent{I:6} + // Received: event.otherEvent{S:"whoa"} + // done +} |