refreshable

type Bool interface {
	Refreshable
	CurrentBool() bool
	MapBool(func(bool) interface{}) Refreshable
	SubscribeToBool(func(bool)) (unsubscribe func())
}

type BoolPtr interface {
	Refreshable
	CurrentBoolPtr() *bool
	MapBoolPtr(func(*bool) interface{}) Refreshable
	SubscribeToBoolPtr(func(*bool)) (unsubscribe func())
}

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

type Duration interface {
	Refreshable
	CurrentDuration() time.Duration
	MapDuration(func(time.Duration) interface{}) Refreshable
	SubscribeToDuration(func(time.Duration)) (unsubscribe func())
}

type DurationPtr interface {
	Refreshable
	CurrentDurationPtr() *time.Duration
	MapDurationPtr(func(*time.Duration) interface{}) Refreshable
	SubscribeToDurationPtr(func(*time.Duration)) (unsubscribe func())
}

type Int interface {
	Refreshable
	CurrentInt() int
	MapInt(func(int) interface{}) Refreshable
	SubscribeToInt(func(int)) (unsubscribe func())
}

type IntPtr interface {
	Refreshable
	CurrentIntPtr() *int
	MapIntPtr(func(*int) interface{}) Refreshable
	SubscribeToIntPtr(func(*int)) (unsubscribe func())
}

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
	MapString(func(string) interface{}) Refreshable
	SubscribeToString(func(string)) (unsubscribe func())
}

type StringPtr interface {
	Refreshable
	CurrentStringPtr() *string
	MapStringPtr(func(*string) interface{}) Refreshable
	SubscribeToStringPtr(func(*string)) (unsubscribe func())
}

type StringSlice interface {
	Refreshable
	CurrentStringSlice() []string
	MapStringSlice(func([]string) interface{}) Refreshable
	SubscribeToStringSlice(func([]string)) (unsubscribe func())
}

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