refreshable

Mar 25, 2026

Changes in this version

type Refreshable

+ func CachedAuto[T any](original Refreshable[T]) Refreshable[T]

+ func CollectAuto[T any](list ...Refreshable[T]) Refreshable[[]T]

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

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

+ func MapFromValidatedCheckedAuto[T any, M any](original Validated[T], mapFn func(T) M) (Refreshable[M], error)

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

type Validated

+ func CollectValidatedAuto[T any](list ...Validated[T]) Validated[[]T]

+ func MapValidatedAuto[T any, M any](ctx context.Context, original Validated[T], ...) (Validated[M], error)

+ func MapWithErrorAuto[T any, M any](ctx context.Context, original Refreshable[T], ...) (Validated[M], error)

+ func MergeValidatedAndRefreshableAuto[T1 any, T2 any, R any](ctx context.Context, original1 Validated[T1], refreshable1 Refreshable[T2], ...) Validated[R]

+ func MergeValidatedAuto[T1 any, T2 any, R any](original1 Validated[T1], original2 Validated[T2], mergeFn func(T1, T2) R) Validated[R]

+ func ValidateAuto[T any](ctx context.Context, original Refreshable[T], ...) (Validated[T], error)

Mar 18, 2026

Changes in this version

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

Mar 5, 2026

Changes in this version

+ func MapFromValidated[T any, M any](original Validated[T], mapFn func(T) M) (Refreshable[M], UnsubscribeFunc)

+ func MergeValidatedAndRefreshable[T1 any, T2 any, R any](ctx context.Context, original1 Validated[T1], refreshable1 Refreshable[T2], ...) (Validated[R], UnsubscribeFunc)

Mar 5, 2026

Changes in this version

+ func CollectValidatedMutable[T any](list ...Validated[T]) (Validated[[]T], ValidatedAddFunc[T], UnsubscribeFunc)

+ func CollectValidated[T any](list ...Validated[T]) (Validated[[]T], UnsubscribeFunc)

+ func MapValidated[T any, M any](ctx context.Context, original Validated[T], ...) (Validated[M], UnsubscribeFunc, error)

+ func MergeValidated[T1 any, T2 any, R any](original1 Validated[T1], original2 Validated[T2], mergeFn func(T1, T2) R) (Validated[R], UnsubscribeFunc)

+ type ChangeDetector interface

+ MarkUpdated func()

+ ShouldUpdate func(ctx context.Context) bool

+ func NewAlwaysCheckChangeDetector() ChangeDetector

type Validated

+ func NewRefreshableTickerWithDuration[M any](ctx context.Context, a time.Duration, ...) Validated[M]

+ func NewRefreshableTicker[M any](ctx context.Context, updateTicker <-chan time.Time, ...) Validated[M]

+ SubscribeValidated func(consumer func(Validated[T])) UnsubscribeFunc

+ Unvalidated func() T

+ type ValidatedAddFunc func(Validated[T])

Feb 12, 2026

Changes in this version

type Validated

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

Feb 3, 2026

Changes in this version

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

+ type AddFunc func(Refreshable[T])

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)