channels

Documentation

Index

• func IterContext[T any](ctx context.Context, ch <-chan T) iter.Seq[T]
• type Notifier
  • func NewNotifier(ctx context.Context) *Notifier
  • func (b *Notifier) Notify(ctx context.Context)
  • func (b *Notifier) Subscribe() <-chan struct{}

Functions

func IterContext

func IterContext[T any](ctx context.Context, ch <-chan T) iter.Seq[T]

IterContext returns an iterator that iterates over the channel until the channel is closed or the context cancelled.

Check ctx.Err() != nil to detect if the context was cancelled.

Types

type Notifier

type Notifier struct {
	// contains filtered or unexported fields
}

Notifier helps to notify multiple subscribers that an event has occurred.

func NewNotifier

func NewNotifier(ctx context.Context) *Notifier

NewNotifier creates a new Notifier instance.

The returned Notifier will automatically close all subscribers when the context is cancelled.

func (*Notifier) Notify

func (b *Notifier) Notify(ctx context.Context)

Notify all subscribers.

func (*Notifier) Subscribe

func (b *Notifier) Subscribe() <-chan struct{}

Subscribe to the notifier.

The returned channel will be closed when the notifier context is cancelled.