Versions in this module Expand all Collapse all v0 v0.0.8 May 7, 2024 Changes in this version + type PubSub struct + func New[Message any]() *PubSub[Message] + func (b *PubSub[Message]) Publish(message Message) error + func (b *PubSub[Message]) Subscribe(filter channel.MessageFilter[Message]) (<-chan Message, error) + func (b *PubSub[Message]) Unsubscribe(subscriber <-chan Message) error