refreshable

type Bool interface {
	Refreshable
	CurrentBool() bool
}

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

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

type Int interface {
	Refreshable
	CurrentInt() 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
}