eventstream

Oct 29, 2023

Changes in this version

+ type EventsStream struct

+ func (b *EventsStream) AddSubscriber() Subscriber

+ func (b *EventsStream) Broadcast(msg any, topics []string)

+ func (b *EventsStream) Close()

+ func (b *EventsStream) Publish(topic string, msg any)

+ func (b *EventsStream) RemoveSubscriber(sub Subscriber)

+ func (b *EventsStream) Subscribe(sub Subscriber, topic string)

+ func (b *EventsStream) SubscribersCount(topic string) int

+ func (b *EventsStream) Unsubscribe(sub Subscriber, topic string)

+ type Message struct

+ func NewMessage(topic string, payload any) *Message

+ func (m Message) Payload() any

+ func (m Message) Topic() string

+ type Stream interface

+ AddSubscriber func() Subscriber

+ Broadcast func(msg any, topics []string)

+ Close func()

+ Publish func(topic string, msg any)

+ RemoveSubscriber func(sub Subscriber)

+ Subscribe func(sub Subscriber, topic string)

+ SubscribersCount func(topic string) int

+ Unsubscribe func(sub Subscriber, topic string)

+ func New() Stream

+ type Subscriber interface

+ Active func() bool

+ ID func() string

+ Iterator func() chan *Message

+ Shutdown func()

+ Topics func() []string

+ type Subscribers map[string]Subscriber