Add Operation Timeouts (#18)

* Add option to pass in TCP and UNIX stream socket timeouts

* Update examples to pass in an op_timeout option when connecting

* cargo fmt

* Add optional read, write, and connect timeout to ConnectOpts

README.md

@@ -70,6 +70,4 @@ at your option.
 
 ### Contribution
 
-Unless you explicitly state otherwise, any contribution intentionally submitted
-for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any
-additional terms or conditions.
+Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

examples/basic.rs

@@ -20,16 +20,10 @@ fn main() {
     assert_eq!(&value[..], b"Bar");
     assert_eq!(flags, 0xdead_beef);
 
-    client
-        .set_noreply(b"key:dontreply", b"1", 0x00_00_00_01, 20)
-        .unwrap();
+    client.set_noreply(b"key:dontreply", b"1", 0x00_00_00_01, 20).unwrap();
 
-    let (_, cas_val) = client
-        .increment_cas(b"key:numerical", 10, 1, 20, 0)
-        .unwrap();
-    client
-        .increment_cas(b"key:numerical", 1, 1, 20, cas_val)
-        .unwrap();
+    let (_, cas_val) = client.increment_cas(b"key:numerical", 10, 1, 20, 0).unwrap();
+    client.increment_cas(b"key:numerical", 1, 1, 20, cas_val).unwrap();
 
     let mut handlers = Vec::new();
     for _ in 0..4 {
@@ -38,9 +32,7 @@ fn main() {
             let (_, _, mut cas) = client.get_cas(b"key:dontreply").unwrap();
             for _ in 0..100 {
                 debug!("Setting in {:?}", thread::current());
-                client
-                    .set_cas(b"key:dontreply", b"1", 0x00_10_01, 20, cas)
-                    .unwrap();
+                client.set_cas(b"key:dontreply", b"1", 0x00_10_01, 20, cas).unwrap();
                 cas = client.get_cas(b"key:dontreply").unwrap().2;
             }
         });

examples/sasl.rs

@@ -5,8 +5,7 @@ use memcached::Client;
 
 fn main() {
     let servers = [("tcp://my-sasl-memcached-server.com:11211", 1)];
-    let mut client =
-        Client::connect_sasl(&servers, ProtoType::Binary, "my-username", "my-password").unwrap();
+    let mut client = Client::connect_sasl(&servers, ProtoType::Binary, "my-username", "my-password").unwrap();
 
     client.set(b"Foo", b"Bar", 0xdead_beef, 2).unwrap();
     let (value, flags) = client.get(b"Foo").unwrap();

examples/unixsocket.rs

@@ -18,14 +18,8 @@ fn main() {
     assert_eq!(&value[..], b"Bar");
     assert_eq!(flags, 0xdead_beef);
 
-    client
-        .set_noreply(b"key:dontreply", b"1", 0x00_00_00_01, 20)
-        .unwrap();
+    client.set_noreply(b"key:dontreply", b"1", 0x00_00_00_01, 20).unwrap();
 
-    let (_, cas_val) = client
-        .increment_cas(b"key:numerical", 10, 1, 20, 0)
-        .unwrap();
-    client
-        .increment_cas(b"key:numerical", 1, 1, 20, cas_val)
-        .unwrap();
+    let (_, cas_val) = client.increment_cas(b"key:numerical", 10, 1, 20, 0).unwrap();
+    client.increment_cas(b"key:numerical", 1, 1, 20, cas_val).unwrap();
 }

rustfmt.toml

@@ -1,11 +1,4 @@
 max_width = 120
 fn_call_width = 120
 reorder_imports = true
-reorder_imports_in_group = true
-reorder_imported_names = true
-condense_wildcard_suffixes = true
-fn_args_layout = "Visual"
-fn_call_style = "Visual"
-chain_indent = "Visual"
-normalize_comments = true
 use_try_shorthand = true