README
¶
PubSub
Usage
package main
import (
"github.com/dynport/dgtk/pubsub"
"log"
)
func init() {
log.SetFlags(0)
}
type User struct {
name string
}
func main() {
ps := pubsub.New()
stringSubscription := ps.Subscribe(func(m string) {
log.Printf("got string %q", m)
})
defer stringSubscription.Close()
userSubscription := ps.Subscribe(func(u *User) {
log.Printf("got user %+v", u)
})
defer userSubscription.Close()
ps.Publish("hello")
ps.Publish("world")
ps.Publish(&User{name: "Hans"})
ps.Publish(&User{name: "Meyer"})
}
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
type PubSub struct {
Stats
// contains filtered or unexported fields
}
func (*PubSub) Subscribe ¶
func (pubsub *PubSub) Subscribe(i interface{}) *Subscription
func (*PubSub) SubscribersCount ¶
type Stats ¶
type Stats struct {
// contains filtered or unexported fields
}
func (*Stats) Dispatched ¶
func (*Stats) MessageDispatched ¶
func (stats *Stats) MessageDispatched()
func (*Stats) MessageIgnored ¶
func (stats *Stats) MessageIgnored()
func (*Stats) MessageReceived ¶
func (stats *Stats) MessageReceived()
func (*Stats) StartCollecting ¶
func (stats *Stats) StartCollecting()
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
func (*Subscription) Close ¶
func (subscription *Subscription) Close() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.