Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + func SubscribeWithData(p Subscribable, topic Topic, notifee Notifee) + type Event interface + type EventTransform func(Event) Event + type Notifee struct + Data TopicData + Subscriber *TopicDataSubscriber + type Publisher interface + Close func(Topic) + Publish func(Topic, Event) + Shutdown func() + Startup func() + func NewPublisher() Publisher + type Subscribable interface + Subscribe func(topic Topic, sub Subscriber) bool + Unsubscribe func(sub Subscriber) bool + type Subscriber interface + OnClose func(Topic) + OnNext func(Topic, Event) + type Topic interface + type TopicData interface + type TopicDataSubscriber struct + func NewTopicDataSubscriber(sub Subscriber) *TopicDataSubscriber + func (m *TopicDataSubscriber) AddTopicData(id Topic, data TopicData) + func (m *TopicDataSubscriber) OnClose(topic Topic) + func (m *TopicDataSubscriber) OnNext(topic Topic, ev Event)
Go to main page