beam

type Beam[T1, T2 any] = *beam[T1, T2]

type Beamer[T any] interface {
	Get() T
	Watch(ctx context.Context, w Watcher[T]) (context.CancelFunc, bool)
	// contains filtered or unexported methods
}

type Cinema = *cinema

type Core interface {
	Cinema() Cinema
}

type Door interface {
	Runtime() shredder.Runtime
	ReadFrame() shredder.Frame
	Context() context.Context
}

type Lens[T1, T2 any] = *lens[T1, T2]

type Lenser[T any] interface {
	Beamer[T]
	Update(context.Context, T)
	XUpdate(context.Context, T) <-chan error
	Mutate(context.Context, func(T) T)
	XMutate(context.Context, func(T) T) <-chan error
}

type Source[T any] = *source[T]

type Watcher[T any] interface {
	// Cancel is called when the watcher stops because of context cancellation or
	// an explicit cancel call.
	Cancel()
	// Watch receives the initial value synchronously and later updates
	// asynchronously. Returning true stops the watcher.
	Watch(ctx context.Context, value T) bool
}