We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e12c36 commit 3224315Copy full SHA for 3224315
1 file changed
libsql-server/src/rpc/proxy.rs
@@ -682,21 +682,9 @@ impl Proxy for ProxyService {
682
683
// FIXME: copypasta from execute(), creatively extract to a helper function
684
let lock = self.clients.upgradable_read().await;
685
- let (connection_maker, _new_frame_notifier) = self
+ let connection_maker = self
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();
698
- (connection_maker, notifier)
699
- })
+ .with(ctx.namespace().clone(), |ns| ns.db.connection_maker())
700
.await
701
.map_err(|e| {
702
if let crate::error::Error::NamespaceDoesntExist(_) = e {
0 commit comments