write is mut like read for future proofing

launchdarkly · Jun 20, 2024 · a2c9652 · a2c9652
1 parent 8f952e0
commit a2c9652
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/launchdarkly-server-sdk/src/client.rs b/launchdarkly-server-sdk/src/client.rs
@@ -2029,7 +2029,7 @@ mod tests {
             )
             .expect("patch should apply");
 
-        let migrator = MigratorBuilder::new(client.clone())
+        let mut migrator = MigratorBuilder::new(client.clone())
             .track_latency(true)
             .read(
                 |_| async move { Ok(serde_json::Value::Null) }.boxed(),
@@ -2120,7 +2120,7 @@ mod tests {
             )
             .expect("patch should apply");
 
-        let migrator = MigratorBuilder::new(client.clone())
+        let mut migrator = MigratorBuilder::new(client.clone())
             .track_latency(true)
             .read(
                 |_| async move { Ok(serde_json::Value::Null) }.boxed(),

diff --git a/launchdarkly-server-sdk/src/migrations/migrator.rs b/launchdarkly-server-sdk/src/migrations/migrator.rs
@@ -294,7 +294,7 @@ where
 
     /// Uses the provided flag key and context to execute a migration-backed write operation.
     pub async fn write(
-        &self,
+        &mut self,
         context: &Context,
         flag_key: String,
         default_stage: Stage,
@@ -600,7 +600,7 @@ mod tests {
         let (sender, receiver) = mpsc::channel();
         let old_sender = sender.clone();
         let new_sender = sender.clone();
-        let migrator = MigratorBuilder::new(client)
+        let mut migrator = MigratorBuilder::new(client)
             .track_latency(false)
             .track_errors(false)
             .read(
@@ -866,7 +866,7 @@ mod tests {
         let (sender, receiver) = mpsc::channel();
         let old_sender = sender.clone();
         let new_sender = sender.clone();
-        let migrator = MigratorBuilder::new(client)
+        let mut migrator = MigratorBuilder::new(client)
             .track_latency(false)
             .track_errors(false)
             .read(
@@ -951,7 +951,7 @@ mod tests {
         let (sender, receiver) = mpsc::channel();
         let old_sender = sender.clone();
         let new_sender = sender.clone();
-        let migrator = MigratorBuilder::new(client)
+        let mut migrator = MigratorBuilder::new(client)
             .track_latency(false)
             .track_errors(false)
             .read(