Versions in this module Expand all Collapse all v1 v1.0.0 Dec 9, 2024 Changes in this version + type Service struct + func NewService() *Service + func (s *Service) Cleanup() error + func (s *Service) Publish(name string, message interface{}) + func (s *Service) Subscribe(name string) *Subscriber + type Subscriber struct + func (s *Subscriber) Close() error + func (s *Subscriber) IsClosed() bool + func (s *Subscriber) Wait() <-chan interface{}
Go to main page