reactive

Documentation

Index

• type State
  • func NewState[T any](initialValue T) *State[T]
  • func (rs *State[T]) Get() T
  • func (rs *State[T]) GetTimestamp() time.Time
  • func (rs *State[T]) Subscribe(subscriber StateSubscriber[T])
  • func (rs *State[T]) Update(value T)
• type StateSubscriber

Types

type State

type State[T any] struct {
	// contains filtered or unexported fields
}

func NewState

func NewState[T any](initialValue T) *State[T]

func (*State[T]) Get

func (rs *State[T]) Get() T

func (*State[T]) GetTimestamp

func (rs *State[T]) GetTimestamp() time.Time

func (*State[T]) Subscribe

func (rs *State[T]) Subscribe(subscriber StateSubscriber[T])

func (*State[T]) Update

func (rs *State[T]) Update(value T)

type StateSubscriber

type StateSubscriber[T any] func(old, state *T)