docker/pgcat
1
0
Fork 0
mirror of https://github.com/postgresml/pgcat.git synced 2026-03-28 03:06:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix formatting

Browse Source
This commit is contained in:
Kevin Zimmerman
2023-07-26 09:47:58 -05:00
parent 81536a0bad
commit b4ba3b378c
1 changed files with 20 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/messages.rs
View File

@@ -156,12 +156,10 @@ where
match stream.write_all(&startup).await { match stream.write_all(&startup).await {
Ok(_) => Ok(()), Ok(_) => Ok(()),
Err(err) => { Err(err) => Err(Error::SocketError(format!(
Err(Error::SocketError(format!(
"Error writing startup to server socket - Error: {:?}", "Error writing startup to server socket - Error: {:?}",
err err
))) ))),
}
} }
} }
@@ -564,12 +562,10 @@ where
{ {
match stream.write_all(&buf).await { match stream.write_all(&buf).await {
Ok(_) => Ok(()), Ok(_) => Ok(()),
Err(err) => { Err(err) => Err(Error::SocketError(format!(
Err(Error::SocketError(format!(
"Error writing to socket - Error: {:?}", "Error writing to socket - Error: {:?}",
err err
))) ))),
}
} }
} }
@@ -580,12 +576,10 @@ where
{ {
match stream.write_all(buf).await { match stream.write_all(buf).await {
Ok(_) => Ok(()), Ok(_) => Ok(()),
Err(err) => { Err(err) => Err(Error::SocketError(format!(
Err(Error::SocketError(format!(
"Error writing to socket - Error: {:?}", "Error writing to socket - Error: {:?}",
err err
))) ))),
}
} }
} }
@@ -596,19 +590,15 @@ where
match stream.write_all(buf).await { match stream.write_all(buf).await {
Ok(_) => match stream.flush().await { Ok(_) => match stream.flush().await {
Ok(_) => Ok(()), Ok(_) => Ok(()),
Err(err) => { Err(err) => Err(Error::SocketError(format!(
Err(Error::SocketError(format!(
"Error flushing socket - Error: {:?}", "Error flushing socket - Error: {:?}",
err err
))) ))),
}
}, },
Err(err) => { Err(err) => Err(Error::SocketError(format!(
Err(Error::SocketError(format!(
"Error writing to socket - Error: {:?}", "Error writing to socket - Error: {:?}",
err err
))) ))),
}
} }
} }