notifier

Documentation

Overview

Package notifier implements a Notifier type, which can be used to send broadcast notification to many listeners.

Unlike sync.Cond, here is no delivery guarantee, e.g. if a listener is too busy to pick up the notification, it will be dropped.

Index

• type Listener
  • func (l *Listener[T]) Close()
• type Notifier
  • func (n *Notifier[T]) Len() int
  • func (n *Notifier[T]) NewListener() *Listener[T]
  • func (n *Notifier[T]) Notify(value T)

Types

type Listener

type Listener[T any] struct {
	C <-chan T
	// contains filtered or unexported fields
}

func (*Listener[T]) Close

func (l *Listener[T]) Close()

type Notifier

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

func (*Notifier[T]) Len

func (n *Notifier[T]) Len() int

func (*Notifier[T]) NewListener

func (n *Notifier[T]) NewListener() *Listener[T]

func (*Notifier[T]) Notify

func (n *Notifier[T]) Notify(value T)