goevent

README

go-event

观察者中心

//使用方法
package main

import (
	goevent "github.com/gif-gif/go.io/go-event"
	golog "github.com/gif-gif/go.io/go-log"
	"github.com/gif-gif/go.io/goio"
	"time"
)

func main() {
	goio.Init()
	event := goevent.New()
	event.Subscribe("test", func(msg goevent.Message) {
		golog.WithTag("goevent").Info(msg)
	})
	event.Publish("test", "test")
	time.Sleep(time.Duration(1) * time.Second)
}

Documentation

Index

• func Publish(topic string, data interface{})
• func Subscribe(topic string, fn SubscribeFunc)
• type Event
  • func Default() *Event
  • func New() *Event
  • func (ev *Event) Publish(topic string, data interface{})
  • func (ev *Event) Subscribe(topic string, fn SubscribeFunc)
• type Message
• type MessageChan
• type SubscribeFunc

Functions

func Publish

func Publish(topic string, data interface{})

func Subscribe

func Subscribe(topic string, fn SubscribeFunc)

Types

type Event

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

func Default

func Default() *Event

func New

func New() *Event

func (*Event) Publish

func (ev *Event) Publish(topic string, data interface{})

发布 执行当前topic 对应的所有订阅者

func (*Event) Subscribe

func (ev *Event) Subscribe(topic string, fn SubscribeFunc)

订阅：一个topic可以对应多个处理器，（topic->handler 的关系是1:n）,一次添加一个订阅者

type Message

type Message struct {
	Topic string
	Data  interface{}
}

type MessageChan

type MessageChan chan Message

type SubscribeFunc

type SubscribeFunc func(msg Message)