Feat: Unobserve a state

pkg/app/context.go

@@ -30,6 +30,7 @@ type Context struct {
 	handleAction          func(string, UI, bool, ActionHandler)
 	postAction            func(Context, Action)
 	observeState          func(Context, string, any) Observer
+	unObserveState        func(Context, string)
 	getState              func(Context, string, any)
 	setState              func(Context, string, any) State
 	delState              func(Context, string)
@@ -279,6 +280,10 @@ func (ctx Context) ObserveState(state string, recv any) Observer {
 	return ctx.observeState(ctx, state, recv)
 }
 
+func (ctx Context) UnObserveState(state string) {
+	ctx.unObserveState(ctx, state)
+}
+
 // GetState fetches the value of a particular state.
 func (ctx Context) GetState(state string, recv any) {
 	ctx.getState(ctx, state, recv)

pkg/app/engine.go

@@ -90,6 +90,7 @@ func (e *engineX) baseContext() Context {
 		handleAction:          e.actions.Handle,
 		postAction:            e.actions.Post,
 		observeState:          e.states.Observe,
+		unObserveState:        e.states.UnObserve,
 		getState:              e.states.Get,
 		setState:              e.states.Set,
 		delState:              e.states.Delete,

pkg/app/state.go

@@ -414,6 +414,17 @@ func (m *stateManager) Delete(ctx Context, state string) {
 	ctx.LocalStorage().Del(state)
 }
 
+func (m *stateManager) UnObserve(ctx Context, state string) {
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
+	for src := range m.observers[state] {
+		if src == ctx.Src() {
+			delete(m.observers[state], src)
+		}
+	}
+}
+
 // Cleanup removes observers that are no longer active and cleans up any states
 // without observers.
 func (m *stateManager) Cleanup() {