refreshable

type Bool interface {
	Refreshable
	CurrentBool() bool
}

type BoolPtr interface {
	Refreshable
	CurrentBoolPtr() *bool
}

type DefaultRefreshable struct {
	sync.Mutex // protects subscribers
	// contains filtered or unexported fields
}

type Duration interface {
	Refreshable
	CurrentDuration() time.Duration
}

type DurationPtr interface {
	Refreshable
	CurrentDurationPtr() *time.Duration
}

type Int interface {
	Refreshable
	CurrentInt() int
}

type IntPtr interface {
	Refreshable
	CurrentIntPtr() *int
}

type Refreshable interface {
	// Current returns the most recent value of this Refreshable.
	Current() interface{}

	// Subscribe subscribes to changes of this Refreshable. The provided function is called with the value of Current()
	// whenever the value changes.
	Subscribe(consumer func(interface{})) (unsubscribe func())

	// Map returns a new Refreshable based on the current one that handles updates based on the current Refreshable.
	Map(func(interface{}) interface{}) Refreshable
}

type String interface {
	Refreshable
	CurrentString() string
}

type StringPtr interface {
	Refreshable
	CurrentStringPtr() *string
}

type StringSlice interface {
	Refreshable
	CurrentStringSlice() []string
}

type ValidatingRefreshable struct {
	Refreshable
	// contains filtered or unexported fields
}