Remove some mut / write locks

schroeder- · Aug 5, 2021 · 7263c90 · 7263c90
1 parent 2e26b19
commit 7263c90
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/integration/src/tests.rs b/integration/src/tests.rs
@@ -408,15 +408,15 @@ fn read_write_read() {
 
             // Read the existing value
             {
-                let mut session = session.write().unwrap();
+                let session = session.read().unwrap();
                 let results = session.read(&[node_id.clone().into()]).unwrap();
                 let value = &results[0];
                 debug!("value = {:?}", value);
                 assert_eq!(*value.value.as_ref().unwrap(), Variant::Int32(0))
             }
 
             {
-                let mut session = session.write().unwrap();
+                let session = session.read().unwrap();
                 let results = session
                     .write(&[WriteValue {
                         node_id: node_id.clone(),
@@ -430,14 +430,14 @@ fn read_write_read() {
             }
 
             {
-                let mut session = session.write().unwrap();
+                let session = session.read().unwrap();
                 let results = session.read(&[node_id.into()]).unwrap();
                 let value = &results[0];
                 assert_eq!(*value.value.as_ref().unwrap(), Variant::Int32(1))
             }
 
             {
-                let mut session = session.write().unwrap();
+                let session = session.read().unwrap();
                 session.disconnect();
             }
         },
@@ -464,7 +464,7 @@ fn subscribe_1000() {
             let session = client
                 .connect_to_endpoint(client_endpoint, identity_token)
                 .unwrap();
-            let mut session = session.write().unwrap();
+            let session = session.read().unwrap();
 
             let start_time = Utc::now();