eventbus

Feb 24, 2020

Changes in this version

+ type Broker struct

+ StreamMap map[string]observer.Property

+ var DefaultBrooker *Broker

+ func NewBroker() *Broker

+ func (b *Broker) GetPublisher(topic string) *Publisher

+ func (b *Broker) GetSubscriber(topic string, Handle func(i interface{}) error) *Subscriber

+ type Publisher struct

+ Broker *Broker

+ Topic string

+ func (p *Publisher) Publish(data interface{})

+ type Subscriber struct

+ Broker *Broker

+ Handle func(i interface{}) error

+ Topic string

+ func (s *Subscriber) Subscribe()

+ func (s *Subscriber) Unsubscribe()