refreshable

Dec 17, 2025

Changes in this version

type Validated

+ func MapValues[K comparable, V, R any](ctx context.Context, refreshableMap Refreshable[map[K]V], ...) Validated[map[K]R]

+ func NewMultiFileRefreshable(ctx context.Context, paths Refreshable[map[string]struct{}]) Validated[map[string][]byte]

Nov 4, 2025

Changes in this version

type Validated

+ func NewFileRefreshable(ctx context.Context, filePath string) Validated[[]byte]

+ func NewFileRefreshableWithTicker(ctx context.Context, filePath string, updateTicker <-chan time.Time) Validated[[]byte]

Jan 21, 2025

Changes in this version

+ func Cached[T any](original Refreshable[T]) (Refreshable[T], UnsubscribeFunc)

+ func Collect[T any](list ...Refreshable[T]) (Refreshable[[]T], UnsubscribeFunc)

+ func Merge[T1 any, T2 any, R any](original1 Refreshable[T1], original2 Refreshable[T2], mergeFn func(T1, T2) R) (Refreshable[R], UnsubscribeFunc)

type Refreshable

+ func View[T any, M any](original Refreshable[T], mapFn func(T) M) Refreshable[M]

Aug 10, 2023

Changes in this version

+ func Map(original Refreshable[T], mapFn func(T) M) (Refreshable[M], UnsubscribeFunc)

+ func MapWithError(original Refreshable[T], mapFn func(T) (M, error)) (Validated[M], UnsubscribeFunc, error)

+ func NewFromTickerFunc(ctx context.Context, interval time.Duration, ...) (Ready[T], UnsubscribeFunc)

+ func Validate(original Refreshable[T], validatingFn func(T) error) (Validated[T], UnsubscribeFunc, error)

+ func Wait(ctx context.Context, ready Ready[T]) (T, bool)

+ type Ready interface

+ ReadyC func() <-chan struct{}

+ func NewFromChannel(values <-chan T) Ready[T]

+ type Refreshable interface

+ Current func() T

+ Subscribe func(consumer func(T)) UnsubscribeFunc

+ func MapContext(ctx context.Context, original Refreshable[T], mapFn func(T) M) Refreshable[M]

+ type UnsubscribeFunc func()

+ type Updatable interface

+ Update func(T)

+ func New(val T) Updatable[T]

+ type Validated interface

+ Validation func() (T, error)