We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 35bfc4e commit 0e86ecbCopy full SHA for 0e86ecb
crates/core/src/sync/storage_adapter.rs
@@ -323,7 +323,7 @@ impl StorageAdapter {
323
324
fn delete_outdated_subscriptions(&self) -> Result<(), PowerSyncError> {
325
self.db
326
- .exec_safe("DELETE FROM ps_stream_subscriptions WHERE expires_at < unixepoch()")?;
+ .exec_safe("DELETE FROM ps_stream_subscriptions WHERE (expires_at < unixepoch()) OR (ttl IS NULL AND NOT active)")?;
327
Ok(())
328
}
329
0 commit comments