Fix projection updates getting stuck

OpenSlides · Jan 27, 2025 · 6785c5c · 6785c5c
1 parent 2865f0f
commit 6785c5c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/datastore/subscribe.go b/pkg/datastore/subscribe.go
@@ -61,7 +61,7 @@ func (q *query[T, PT]) Subscribe() *subscription[<-chan map[string]map[string]in
 	}()
 
 	return &subscription[<-chan map[string]map[string]interface{}]{q.datastore, updateChannel, func() error { return nil }, notifyChannel, func() {
-		close(notifyChannel)
+		q.datastore.change.RemoveListener <- updateChannel
 	}}
 }
 
@@ -141,7 +141,7 @@ func (q *query[T, PT]) SubscribeOne(model PT) (*subscription[<-chan []string], e
 	}()
 
 	return &subscription[<-chan []string]{q.datastore, updateChannel, load, notifyChannel, func() {
-		close(notifyChannel)
+		q.datastore.change.RemoveListener <- updateChannel
 	}}, nil
 }