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 66771bf commit dbce920Copy full SHA for dbce920
crates/core/src/sync/storage_adapter.rs
@@ -350,7 +350,7 @@ impl StorageAdapter {
350
351
fn delete_outdated_subscriptions(&self) -> Result<(), PowerSyncError> {
352
self.db
353
- .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)")?;
354
Ok(())
355
}
356
0 commit comments