change: update tokio

.travis.yml

@@ -8,3 +8,7 @@ os:
 
 script:
     - cargo test --all-features
+    - cd examples/server
+    - cargo check
+    - cd ../../examples/client
+    - cargo check

Cargo.toml

@@ -26,6 +26,3 @@ tokio = "0.1"
 [features]
 default = [ "unstable-futures", "tokio" ]
 unstable-futures = [ "futures", "tokio/unstable-futures" ]
-
-[patch.crates-io]
-tokio = { git = "https://github.com/tokio-rs/tokio" }

appveyor.yml

@@ -1,9 +1,7 @@
 environment:
   matrix:
       - TARGET: x86_64-pc-windows-msvc
-        BITS: 64
       - TARGET: i686-pc-windows-msvc
-        BITS: 32
 
 install:
     - appveyor DownloadFile https://win.rustup.rs/ -FileName rustup-init.exe
@@ -16,3 +14,7 @@ build: false
 
 test_script:
     - 'cargo test --all-features'
+    - 'cd examples/server'
+    - 'cargo check'
+    - 'cd ../../examples/client'
+    - 'cargo check'

examples/server/Cargo.toml

@@ -11,7 +11,3 @@ tokio = { version = "0.1", features = [ "unstable-futures" ] }
 futures = "0.2.0-beta"
 
 clap = "2.26"
-
-
-[patch.crates-io]
-tokio = { git = "https://github.com/tokio-rs/tokio" }

src/lib.rs

@@ -117,14 +117,7 @@ impl<S, C> io::Read for TlsStream<S, C>
             return Ok(0);
         }
 
-        // TODO nll
+        match Stream::new(&mut self.session, &mut self.io).read(buf) {
-        let result = {
-            let (io, session) = self.get_mut();
-            let mut stream = Stream::new(session, io);
-            stream.read(buf)
-        };
-
-        match result {
             Ok(0) => { self.eof = true; Ok(0) },
             Ok(n) => Ok(n),
             Err(ref e) if e.kind() == io::ErrorKind::ConnectionAborted => {
@@ -142,19 +135,11 @@ impl<S, C> io::Write for TlsStream<S, C>
     where S: io::Read + io::Write, C: Session
 {
     fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
-        let (io, session) = self.get_mut();
+        Stream::new(&mut self.session, &mut self.io).write(buf)
-        let mut stream = Stream::new(session, io);
-
-        stream.write(buf)
     }
 
     fn flush(&mut self) -> io::Result<()> {
-        {
+        Stream::new(&mut self.session, &mut self.io).flush()?;
-            let (io, session) = self.get_mut();
-            let mut stream = Stream::new(session, io);
-            stream.flush()?;
-        }
-
         self.io.flush()
     }
 }