observer

package

v1.15.2 Latest Latest Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Property interface {
	Value() any
	Update(any)
	Observe() Stream
}

Property stores a value and allows observers to subscribe to updates.

func NewProperty(value any) Property

NewProperty creates a property with the provided initial value.

type Stream interface {
	Value() any
	Changes() chan struct{}
	Next() any
	WaitNext() any
	HasNext() bool
	Clone() Stream
}

Stream observes updates to a Property.