blocking

Documentation

Index

• type PubSub
  • 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

Types

type PubSub

type PubSub[Message any] struct {
	// contains filtered or unexported fields
}

PubSub is a broadcaster that block when publishing without any subscribers

func New

func New[Message any]() *PubSub[Message]

func (*PubSub[Message]) Publish

func (b *PubSub[Message]) Publish(message Message) error

Publish a message to a topic is blocking, if the receiver does not read the message in time, it will return an error

func (*PubSub[Message]) Subscribe

func (b *PubSub[Message]) Subscribe(filter channel.MessageFilter[Message]) (<-chan Message, error)

func (*PubSub[Message]) Unsubscribe

func (b *PubSub[Message]) Unsubscribe(subscriber <-chan Message) error