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 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() (done chan struct{})
}

type Payload struct {
	Action ActionInterface
	Done   chan 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 WatcherInterface interface {
	Watch(key interface{}, f func(done chan struct{}))
	Delete(key interface{})
}