flux

type ActionInterface interface{}

type AppInterface interface {
	WatcherInterface
	DispatcherInterface
}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type DispatcherInterface interface {
	Dispatch(action ActionInterface) chan struct{}
}

type Notif interface {
	IsNotif()
}

type NotifPayload struct {
	Type Notif
	Done chan struct{}
	Data interface{}
}

type Notifier struct {
	// contains filtered or unexported fields
}

type NotifierInterface interface {
	// Notify sends the notif notification to all subscribers of that
	// notification for object. If object is nil, the notification is sent to
	// all subscribers. The chanel returned is closed when the notify action
	// has finished.
	Notify(object interface{}, notif Notif, data interface{}) (done chan struct{})
}

type Payload struct {
	Action ActionInterface
	Done   chan struct{}
	// contains filtered or unexported fields
}

type Store struct {
	// contains filtered or unexported fields
}

type StoreInterface interface {
	// Handle consumes the action in the payload. If the operation was performed syncronously,
	// return true. If not, return false and close the payload.Done channel when finished.
	Handle(payload *Payload) (finished bool)
}

type View struct {
	vecty.Core
	Ctx    context.Context
	App    AppInterface
	Notifs []chan NotifPayload
	Self   ViewInterface
	// contains filtered or unexported fields
}

type ViewInterface interface {
	vecty.Component
	Receive(notif NotifPayload)
}

type Waiter struct {
	// contains filtered or unexported fields
}

type WatcherInterface interface {
	// Watch returns a channel subscribed to reveive notifs notifications about
	// object. If object is nil, the subscription is for all objects in the
	// store.
	Watch(object interface{}, notif ...Notif) chan NotifPayload
	Delete(c chan NotifPayload)
}