Send is now &mut self

2 files changed, 3 insertions, 3 deletions

diff --git a/talpid_ipc/src/zmq_ipc.rs b/talpid_ipc/src/zmq_ipc.rs
index 0e8f18517f..d39249bd6f 100644
--- a/talpid_ipc/src/zmq_ipc.rs
+++ b/talpid_ipc/src/zmq_ipc.rs
@@ -58,12 +58,12 @@ impl IpcClient {
         }
     }
 
-    pub fn send(mut self, message: &[u8]) -> Result<()> {
+    pub fn send(&mut self, message: &[u8]) -> Result<()> {
         if self.socket.is_none() {
             self.connect().chain_err(|| ErrorKind::SendError)?;
         }
 
-        let socket = self.socket.unwrap();
+        let socket = self.socket.as_ref().unwrap();
         socket.send(message, 0).chain_err(|| ErrorKind::SendError)
     }
 
diff --git a/talpid_ipc/tests/zmq_integration_tests.rs b/talpid_ipc/tests/zmq_integration_tests.rs
index c72549a837..b7993c3553 100644
--- a/talpid_ipc/tests/zmq_integration_tests.rs
+++ b/talpid_ipc/tests/zmq_integration_tests.rs
@@ -17,7 +17,7 @@ mod zmq_integration_tests {
     fn can_connect_and_send_and_receive_messages() {
         let (connection_string, new_messages_rx) = start_server();
 
-        let ipc_client = IpcClient::new(connection_string);
+        let mut ipc_client = IpcClient::new(connection_string);
         ipc_client.send(&[1, 3, 3, 7]).expect("Could not send message");
 
         let message = new_messages_rx.recv_timeout(Duration::from_millis(1000))