Fix for IO changes

3 files changed, 18 insertions, 18 deletions

diff --git a/src/ssl/error.rs b/src/ssl/error.rs
index 4f05e449..2aa77fb0 100644
--- a/src/ssl/error.rs
+++ b/src/ssl/error.rs
@@ -5,7 +5,7 @@ use libc::c_ulong;
 use std::error;
 use std::fmt;
 use std::ffi::c_str_to_bytes;
-use std::io::IoError;
+use std::old_io::IoError;
 
 use ffi;
 
diff --git a/src/ssl/mod.rs b/src/ssl/mod.rs
index 3e7cd182..35649e24 100644
--- a/src/ssl/mod.rs
+++ b/src/ssl/mod.rs
@@ -1,6 +1,6 @@
 use libc::{c_int, c_void, c_long};
 use std::ffi::{CString, c_str_to_bytes};
-use std::io::{IoResult, IoError, EndOfFile, Stream, Reader, Writer};
+use std::old_io::{IoResult, IoError, EndOfFile, Stream, Reader, Writer};
 use std::mem;
 use std::fmt;
 use std::num::FromPrimitive;
@@ -291,8 +291,8 @@ impl<'ssl> MemBioRef<'ssl> {
         (&mut self.bio as &mut Reader).read(buf).ok()
     }
 
-    fn write(&mut self, buf: &[u8]) {
-        let _ = (&mut self.bio as &mut Writer).write(buf);
+    fn write_all(&mut self, buf: &[u8]) {
+        let _ = (&mut self.bio as &mut Writer).write_all(buf);
     }
 }
 
@@ -357,7 +357,7 @@ impl Ssl {
                                buf.len() as c_int) }
     }
 
-    fn write(&self, buf: &[u8]) -> c_int {
+    fn write_all(&self, buf: &[u8]) -> c_int {
         unsafe { ffi::SSL_write(self.ssl.0, buf.as_ptr() as *const c_void,
                                 buf.len() as c_int) }
     }
@@ -510,7 +510,7 @@ impl<S: Stream> SslStream<S> {
                 LibSslError::ErrorWantRead => {
                     try_ssl_stream!(self.flush());
                     let len = try_ssl_stream!(self.stream.read(self.buf.as_mut_slice()));
-                    self.ssl.get_rbio().write(&self.buf[..len]);
+                    self.ssl.get_rbio().write_all(&self.buf[..len]);
                 }
                 LibSslError::ErrorWantWrite => { try_ssl_stream!(self.flush()) }
                 LibSslError::ErrorZeroReturn => return Err(SslSessionClosed),
@@ -523,7 +523,7 @@ impl<S: Stream> SslStream<S> {
     fn write_through(&mut self) -> IoResult<()> {
         loop {
             match self.ssl.get_wbio().read(self.buf.as_mut_slice()) {
-                Some(len) => try!(self.stream.write(&self.buf[..len])),
+                Some(len) => try!(self.stream.write_all(&self.buf[..len])),
                 None => break
             };
         }
@@ -565,11 +565,11 @@ impl<S: Stream> Reader for SslStream<S> {
 }
 
 impl<S: Stream> Writer for SslStream<S> {
-    fn write(&mut self, buf: &[u8]) -> IoResult<()> {
+    fn write_all(&mut self, buf: &[u8]) -> IoResult<()> {
         let mut start = 0;
         while start < buf.len() {
             let ret = self.in_retry_wrapper(|ssl| {
-                ssl.write(buf.split_at(start).1)
+                ssl.write_all(buf.split_at(start).1)
             });
             match ret {
                 Ok(len) => start += len as usize,
@@ -605,10 +605,10 @@ impl<S> Reader for MaybeSslStream<S> where S: Stream {
 }
 
 impl<S> Writer for MaybeSslStream<S> where S: Stream{
-    fn write(&mut self, buf: &[u8]) -> IoResult<()> {
+    fn write_all(&mut self, buf: &[u8]) -> IoResult<()> {
         match *self {
-            MaybeSslStream::Ssl(ref mut s) => s.write(buf),
-            MaybeSslStream::Normal(ref mut s) => s.write(buf),
+            MaybeSslStream::Ssl(ref mut s) => s.write_all(buf),
+            MaybeSslStream::Normal(ref mut s) => s.write_all(buf),
         }
     }
 
diff --git a/src/ssl/tests.rs b/src/ssl/tests.rs
index d78e21c5..77a3118d 100644
--- a/src/ssl/tests.rs
+++ b/src/ssl/tests.rs
@@ -1,6 +1,6 @@
 use serialize::hex::FromHex;
-use std::io::net::tcp::TcpStream;
-use std::io::{Writer};
+use std::old_io::net::tcp::TcpStream;
+use std::old_io::{Writer};
 use std::thread::Thread;
 
 use crypto::hash::HashType::{SHA256};
@@ -179,9 +179,9 @@ fn test_verify_callback_data() {
 fn test_write() {
     let stream = TcpStream::connect("127.0.0.1:15418").unwrap();
     let mut stream = SslStream::new(&SslContext::new(Sslv23).unwrap(), stream).unwrap();
-    stream.write("hello".as_bytes()).unwrap();
+    stream.write_all("hello".as_bytes()).unwrap();
     stream.flush().unwrap();
-    stream.write(" there".as_bytes()).unwrap();
+    stream.write_all(" there".as_bytes()).unwrap();
     stream.flush().unwrap();
 }
 
@@ -189,7 +189,7 @@ fn test_write() {
 fn test_read() {
     let stream = TcpStream::connect("127.0.0.1:15418").unwrap();
     let mut stream = SslStream::new(&SslContext::new(Sslv23).unwrap(), stream).unwrap();
-    stream.write("GET /\r\n\r\n".as_bytes()).unwrap();
+    stream.write_all("GET /\r\n\r\n".as_bytes()).unwrap();
     stream.flush().unwrap();
     stream.read_to_end().ok().expect("read error");
 }
@@ -200,7 +200,7 @@ fn test_clone() {
     let mut stream = SslStream::new(&SslContext::new(Sslv23).unwrap(), stream).unwrap();
     let mut stream2 = stream.clone();
     let _t = Thread::spawn(move || {
-        stream2.write("GET /\r\n\r\n".as_bytes()).unwrap();
+        stream2.write_all("GET /\r\n\r\n".as_bytes()).unwrap();
         stream2.flush().unwrap();
     });
     stream.read_to_end().ok().expect("read error");