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 b924a5a commit c9d8a2dCopy full SHA for c9d8a2d
libsql-wal/benches/benchmarks.rs
@@ -59,7 +59,8 @@ fn with_libsql_conn(f: impl FnOnce(&mut Connection<LibsqlWal<StdIO>>)) {
59
let tmp = tempdir().unwrap();
60
let resolver = |_: &Path| NamespaceName::from_string("test".into());
61
62
- let registry = Arc::new(WalRegistry::new(tmp.path().join("wals"), NoStorage).unwrap());
+ let (sender, _) = tokio::sync::mpsc::channel(12);
63
+ let registry = Arc::new(WalRegistry::new(tmp.path().join("wals"), NoStorage, sender).unwrap());
64
let wal_manager = LibsqlWalManager::new(registry.clone(), Arc::new(resolver));
65
66
let mut conn = libsql_sys::Connection::open(
0 commit comments