@@ -203,13 +203,12 @@ pub fn cancel_query<T>(params: T,
203
203
204
204
fn bad_response ( ) -> io:: Error {
205
205
io:: Error :: new ( io:: ErrorKind :: InvalidInput ,
206
- "the server returned an unexpected response" )
206
+ "the server returned an unexpected response" )
207
207
}
208
208
209
209
fn desynchronized ( ) -> io:: Error {
210
210
io:: Error :: new ( io:: ErrorKind :: Other ,
211
- "communication with the server has desynchronized due to an earlier IO \
212
- error")
211
+ "communication with the server has desynchronized due to an earlier IO error" )
213
212
}
214
213
215
214
/// Specifies the TLS support requested for a new connection.
@@ -414,7 +413,7 @@ impl InnerConnection {
414
413
backend:: Message :: AuthenticationGSS |
415
414
backend:: Message :: AuthenticationSSPI => {
416
415
return Err ( ConnectError :: Io ( io:: Error :: new ( io:: ErrorKind :: Other ,
417
- "unsupported authentication" ) ) )
416
+ "unsupported authentication" ) ) )
418
417
}
419
418
backend:: Message :: ErrorResponse { fields } => return DbError :: new_connect ( fields) ,
420
419
_ => return Err ( ConnectError :: Io ( bad_response ( ) ) ) ,
@@ -507,8 +506,8 @@ impl InnerConnection {
507
506
}
508
507
}
509
508
return Err ( Error :: Io ( io:: Error :: new ( io:: ErrorKind :: InvalidInput ,
510
- "COPY queries cannot be directly \
511
- executed") ) ) ;
509
+ "COPY queries cannot be directly \
510
+ executed") ) ) ;
512
511
}
513
512
_ => {
514
513
self . desynchronized = true ;
@@ -759,7 +758,7 @@ impl InnerConnection {
759
758
for row in rows {
760
759
let raw = row. get ( 0 ) . and_then ( |r| r. as_ref ( ) . map ( |r| & * * r) ) ;
761
760
variants. push ( try!( String :: from_sql_nullable ( & Type :: Name , raw, & ctx)
762
- . map_err ( Error :: Conversion ) ) ) ;
761
+ . map_err ( Error :: Conversion ) ) ) ;
763
762
}
764
763
765
764
Ok ( variants)
0 commit comments