We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e12c36 commit 2da7ce2Copy full SHA for 2da7ce2
libsql-server/src/rpc/proxy.rs
@@ -686,15 +686,7 @@ impl Proxy for ProxyService {
686
.namespaces
687
.with(ctx.namespace().clone(), |ns| {
688
let connection_maker = ns.db.connection_maker();
689
- let notifier = ns
690
- .db
691
- .as_primary()
692
- .unwrap()
693
- .wal_wrapper
694
- .wrapper()
695
- .logger()
696
- .new_frame_notifier
697
- .subscribe();
+ let notifier = ns.db.notifier();
698
(connection_maker, notifier)
699
})
700
.await
0 commit comments