diff --git a/src/lib.rs b/src/lib.rs index 8d993f93..819ab508 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1337,8 +1337,8 @@ fn read_rows(conn: &mut InnerConnection, buf: &mut VecDeque>> } } return Err(Error::Io(std_io::Error::new(std_io::ErrorKind::InvalidInput, - "COPY queries cannot be directly \ - executed"))); + "COPY queries cannot be directly \ + executed"))); } _ => { conn.desynchronized = true; diff --git a/src/rows.rs b/src/rows.rs index 3394dd53..79eccf3d 100644 --- a/src/rows.rs +++ b/src/rows.rs @@ -217,7 +217,7 @@ impl<'a> Row<'a> { { let idx = match idx.idx(self.stmt) { Some(idx) => idx, - None => return None + None => return None, }; let ty = self.stmt.columns()[idx].type_(); diff --git a/src/stmt.rs b/src/stmt.rs index c51cdb9d..644ea23c 100644 --- a/src/stmt.rs +++ b/src/stmt.rs @@ -322,9 +322,9 @@ impl<'conn> Statement<'conn> { match try!(conn.read_message()) { ReadyForQuery { .. } => { return Err(Error::Io(io::Error::new(io::ErrorKind::InvalidInput, - "called `copy_in` on a \ - non-`COPY FROM STDIN` \ - statement"))); + "called `copy_in` on a \ + non-`COPY FROM STDIN` \ + statement"))); } _ => {} } @@ -422,8 +422,8 @@ impl<'conn> Statement<'conn> { } try!(conn.wait_for_ready()); return Err(Error::Io(io::Error::new(io::ErrorKind::InvalidInput, - "called `copy_out` on a non-`COPY TO \ - STDOUT` statement"))); + "called `copy_out` on a non-`COPY TO \ + STDOUT` statement"))); } ErrorResponse { fields } => { try!(conn.wait_for_ready()); @@ -434,9 +434,8 @@ impl<'conn> Statement<'conn> { match try!(conn.read_message()) { ReadyForQuery { .. } => { return Err(Error::Io(io::Error::new(io::ErrorKind::InvalidInput, - "called `copy_out` on a \ - non-`COPY TO STDOUT` \ - statement"))); + "called `copy_out` on a \ + non-`COPY TO STDOUT` statement"))); } _ => {} }