README
¶
事件发布及监听
使用示例
pub := goevent.NewLocalPublisher(16)
//1、注册监听
pub.RegisterListener("TestEvent", goevent.FuncListener(func(event *goevent.Event) error {
fmt.Println("received: ", event)
return nil
}))
//2、发布事件
pub.Publish("TestEvent", fmt.Sprintf("TestEvent body: %d", 1))
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChanListenerRegistrar ¶
type ChanListenerRegistrar struct {
// contains filtered or unexported fields
}
ChanListenerRegistrar 注册listener，监听eventChan中的事件
func NewChanListenerRegistrar ¶
func NewChanListenerRegistrar(eventChan chan *Event) *ChanListenerRegistrar
NewChanListenerRegistrar 注册listener，监听eventChan中的事件
func (*ChanListenerRegistrar) Done ¶
func (lr *ChanListenerRegistrar) Done() (listenDone <-chan struct{})
func (*ChanListenerRegistrar) RegisterListener ¶
func (lr *ChanListenerRegistrar) RegisterListener(eventName string, listeners ...Listener)
func (*ChanListenerRegistrar) StartListen ¶
func (lr *ChanListenerRegistrar) StartListen()
type FuncListener ¶
FuncListener 监听事件
func (FuncListener) Listen ¶
func (f FuncListener) Listen(event *Event) error
type ListenerRegistrar ¶
type ListenerRegistrar interface {
RegisterListener(eventName string, listeners ...Listener)
StartListen()
// Done 是否执行完所有事件
Done() (listenDone <-chan struct{})
}
ListenerRegistrar 注册并监听
type LocalPublisher ¶
type LocalPublisher struct {
ListenerRegistrar
// contains filtered or unexported fields
}
LocalPublisher 发布事件到event chan，支持注册listener和发布事件
func NewLocalPublisher ¶
func NewLocalPublisher(eventBufferSize int) *LocalPublisher
NewLocalPublisher 发布事件到event chan，支持注册listener和发布事件
func (*LocalPublisher) Close ¶
func (p *LocalPublisher) Close()
Source Files
Click to show internal directories.
Click to hide internal directories.