bcast

Documentation

Index

• type Bcast
  • func New[T any](msg <-chan T) *Bcast[T]
  • func (b *Bcast[T]) Close()
  • func (b *Bcast[T]) Run(ctx context.Context, lg *slog.Logger)
  • func (b *Bcast[T]) Subscribe() <-chan T
  • func (b *Bcast[T]) Unsubscribe(ch <-chan T)

Types

type Bcast

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

func New

func New[T any](msg <-chan T) *Bcast[T]

func (*Bcast[T]) Close

func (b *Bcast[T]) Close()

Close stops further broadcasting. Existing subscribers will be closed. Multiple Close calls are safe.

func (*Bcast[T]) Run

func (b *Bcast[T]) Run(ctx context.Context, lg *slog.Logger)

This should be called in a goroutine. It will exit when both - Close has being called on Bcast - the msg channel is closed This should be run in a separate goroutine

func (*Bcast[T]) Subscribe

func (b *Bcast[T]) Subscribe() <-chan T

func (*Bcast[T]) Unsubscribe

func (b *Bcast[T]) Unsubscribe(ch <-chan T)