goreact

README

goreact

light and very simple reactive framework for go In fact this is just an Observer pattern for now Todo

• Operator
• Hot/Cold Signals
• So much more

Documentation

Index

• type Filterable
• type Mappable
• type Mergeable
• type Observable
  • func Observe[T any](signal func(channel chan<- T, err chan<- error)) Observable[T]
• type ObserveStream
  • func (obs ObserveStream[T]) Subscribe(ctx context.Context, next func(T), err func(err error)) context.CancelFunc
  • func (obs ObserveStream[T]) ToMap() Mappable

Types

type Filterable

type Filterable[T any] interface {
	Filter(filter func(elem T) bool)
}

type Mappable

type Mappable[I any, O any] interface {
	Map(mapper func(elem I) O) Observable[O]
}

type Mergeable

type Mergeable[T any] interface {
	Merge(observer ...Observable[T])
}

type Observable

type Observable[T any] interface {
	Subscribe(ctx context.Context, next func(T), err func(err error)) context.CancelFunc
}

func Observe

func Observe[T any](signal func(channel chan<- T, err chan<- error)) Observable[T]

type ObserveStream

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

func (ObserveStream[T]) Subscribe

func (obs ObserveStream[T]) Subscribe(ctx context.Context, next func(T), err func(err error)) context.CancelFunc

func (ObserveStream[T]) ToMap

func (obs ObserveStream[T]) ToMap() Mappable