broadcast

Documentation

Index

• type BroadcastChannel
  • func NewBroadcastChannel[T any]() *BroadcastChannel[T]
  • func (b *BroadcastChannel[T]) Broadcast(ctx context.Context, content T) error
  • func (b *BroadcastChannel[T]) Register() (ReceiverID, <-chan T)
  • func (b *BroadcastChannel[T]) Remove(id ReceiverID)
• type ReceiverID
  • func NewReceiverID() ReceiverID

Types

type BroadcastChannel

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

func NewBroadcastChannel

func NewBroadcastChannel[T any]() *BroadcastChannel[T]

func (*BroadcastChannel[T]) Broadcast

func (b *BroadcastChannel[T]) Broadcast(ctx context.Context, content T) error

func (*BroadcastChannel[T]) Register

func (b *BroadcastChannel[T]) Register() (ReceiverID, <-chan T)

func (*BroadcastChannel[T]) Remove

func (b *BroadcastChannel[T]) Remove(id ReceiverID)

type ReceiverID

type ReceiverID string

func NewReceiverID

func NewReceiverID() ReceiverID