We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 48fe492 commit e249401Copy full SHA for e249401
1 file changed
libsql/src/replication/mod.rs
@@ -149,15 +149,15 @@ impl EmbeddedReplicator {
149
encryption_config: Option<EncryptionConfig>,
150
perodic_sync: Option<Duration>,
151
) -> Result<Self> {
152
- let replicator = Arc::new(Mutex::new(
+ let mut replicator =
153
Replicator::new_sqlite(
154
Either::Left(client),
155
db_path,
156
auto_checkpoint,
157
encryption_config,
158
- )
159
- .await?,
160
- ));
+ ).await?;
+ replicator.set_primary_handshake_retries(3);
+ let replicator = Arc::new(Mutex::new(replicator));
161
162
let mut replicator = Self {
163
replicator,
0 commit comments