notify

package

v0.9.3 Latest Latest Go to latest Published: Jul 19, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func ListenMulti[L any, R any](ctx context.Context, nl *V[L], nr *V[R], fn func(context.Context, L, R) error) error

func MapDelete[M ~map[K]T, K comparable, T any](m *V[M], k K)

func MapDeleteFunc[M ~map[K]T, K comparable, T any](m *V[M], del func(K, T) bool)

func MapPut[M ~map[K]T, K comparable, T any](m *V[M], k K, v T)

func SliceAppend[S []T, T any](v *V[S], val T)

func SliceRemove[S []T, T comparable](v *V[S], val T)

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

func New[T any](t T) *V[T]

func NewEmpty[T any]() *V[T]

func (v *V[T]) Get(ctx context.Context, version uint64) (T, uint64, error)

func (v *V[T]) GetAny(ctx context.Context) (T, uint64, error)

func (v *V[T]) Listen(ctx context.Context, f func(t T) error) error

func (v *V[T]) Notify(ctx context.Context) <-chan T

func (v *V[T]) Peek() (T, error)

func (v *V[T]) Set(t T)

func (v *V[T]) Sync(f func())

func (v *V[T]) Update(f func(t T) T)

func (v *V[T]) UpdateOpt(f func(t T) (T, bool)) bool