space

type Action struct {
	Func func()
	Done chan<- bool
}

type Host interface {
	EventHostId() string
}

type Message struct {
	From       int // user id
	To         int `json:"-"` // user id, -1 means all
	Topic      string
	Attributes map[string]interface{}
	Payload    interface{}
}

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

type Subscriber struct {
	MessageListener chan<- Message
	Done            <-chan bool
}

type Subscription struct {
	MessageListener <-chan Message
	Done            chan<- bool
}

type Thread struct {
	EventStream chan interface{} // Message or Action or Subscriber
	Done        chan bool
	Attribute   sync.Map
}