pubsub

Documentation

Index

• type Publisher
  • func New[T any](logger *slog.Logger) *Publisher[T]
  • func (p *Publisher[T]) Publish(info T)
  • func (p *Publisher[T]) Subscribe() chan T
  • func (p *Publisher[T]) Unsubscribe(ch chan T)

Types

type Publisher

type Publisher[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](logger *slog.Logger) *Publisher[T]

func (*Publisher[T]) Publish

func (p *Publisher[T]) Publish(info T)

func (*Publisher[T]) Subscribe

func (p *Publisher[T]) Subscribe() chan T

func (*Publisher[T]) Unsubscribe

func (p *Publisher[T]) Unsubscribe(ch chan T)