Finish frontend message rewrites

Author: sfackler

src/priv_io.rs

@@ -48,12 +48,6 @@ impl MessageStream {
         self.stream.write_all(&self.buf).map_err(From::from)
     }
 
-    pub fn write_message(&mut self, message: &frontend::Message) -> io::Result<()> {
-        self.buf.clear();
-        try!(frontend::Message::write(message, &mut self.buf));
-        self.stream.write_all(&self.buf)
-    }
-
     fn inner_read_message(&mut self, b: u8) -> io::Result<backend::Message> {
         self.buf.resize(MESSAGE_HEADER_SIZE, 0);
         self.buf[0] = b;

src/stmt.rs

@@ -297,7 +297,7 @@ impl<'conn> Statement<'conn> {
             match fill_copy_buf(&mut buf, r, &info) {
                 Ok(0) => break,
                 Ok(len) => {
-                    try!(info.conn.stream.write_message(&frontend::CopyData { data: &buf[..len] }));
+                    try!(info.conn.stream.write_message2(|out| frontend::copy_data(&buf[..len], out)));
                 }
                 Err(err) => {
                     try!(info.conn.stream.write_message2(|buf| frontend::copy_fail("", buf)));