bus

Documentation

Index

• func Publish(topic string, args ...interface{})
• func Subscribe(topic string, fn interface{}) string
• func SubscribeOnce(topic string, fn interface{}) string
• func SubscribeWithBlock(topic string, fn interface{}) string
• func Unsubscribe(lid string)
• type Bus
  • func (b *Bus) Publish(topic string, args ...interface{})
  • func (b *Bus) Subscribe(l *Listener)
  • func (b *Bus) Unsubscribe(lid string)
• type Listener
  • func NewListener(topic string, fn interface{}, block, once bool) *Listener

Functions

func Publish

func Publish(topic string, args ...interface{})

func Subscribe

func Subscribe(topic string, fn interface{}) string

func SubscribeOnce

func SubscribeOnce(topic string, fn interface{}) string

func SubscribeWithBlock

func SubscribeWithBlock(topic string, fn interface{}) string

func Unsubscribe

func Unsubscribe(lid string)

Types

type Bus

type Bus struct {
	// contains filtered or unexported fields
}

func (*Bus) Publish

func (b *Bus) Publish(topic string, args ...interface{})

func (*Bus) Subscribe

func (b *Bus) Subscribe(l *Listener)

func (*Bus) Unsubscribe

func (b *Bus) Unsubscribe(lid string)

type Listener

type Listener struct {
	// contains filtered or unexported fields
}

func NewListener

func NewListener(topic string, fn interface{}, block, once bool) *Listener