Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broadcaster ¶
type Broadcaster[T any] struct { C chan T // contains filtered or unexported fields }
func New ¶
func New[T any]() *Broadcaster[T]
func (*Broadcaster[T]) Close ¶
func (b *Broadcaster[T]) Close()
func (*Broadcaster[T]) Shutdown ¶
func (b *Broadcaster[T]) Shutdown()
func (*Broadcaster[T]) Start ¶
func (b *Broadcaster[T]) Start(ctx context.Context)
func (*Broadcaster[T]) Subscribe ¶
func (b *Broadcaster[T]) Subscribe() *Subscription[T]
type Subscription ¶
type Subscription[T any] struct { C chan T // contains filtered or unexported fields }
func (*Subscription[T]) Close ¶
func (s *Subscription[T]) Close()
Source Files
Click to show internal directories.
Click to hide internal directories.