pubsub

Jul 17, 2018

Changes in this version

type Service

+ func (s *Service) Cleanup() error

Jul 1, 2018

Changes in this version

+ type Service struct

+ func NewService() *Service

+ func (s *Service) Publish(name string, message interface{})

+ func (s *Service) Subscribe(name string) *Subscriber

+ type Subscriber struct

+ func (s *Subscriber) Close()

+ func (s *Subscriber) IsClosed() bool

+ func (s *Subscriber) Wait() <-chan interface{}