diff --git a/internal/datastore/kvstore.go b/internal/datastore/kvstore.go
index d638fc2..b3d536c 100644
--- a/internal/datastore/kvstore.go
+++ b/internal/datastore/kvstore.go
@@ -178,8 +178,6 @@ func (s *KVStore) Subscribe(ctx context.Context, subscription *apiv1.SubscribeRe
 			if err != nil {
 				return errors.Wrap(err, "failed callback")
 			}
-
-			return nil
 		}
 		return nil
 	})