broadcast

Documentation

Index

• type BroadcastServer
  • func NewBroadcastServer[T any](name string, source <-chan T) BroadcastServer[T]

Types

type BroadcastServer

type BroadcastServer[T any] interface {
	Subscribe() <-chan T
	CancelSubscription(<-chan T)
	Close()
}

func NewBroadcastServer

func NewBroadcastServer[T any](name string, source <-chan T) BroadcastServer[T]