(&mut self, payload: &[u8])
| 1156 | } |
| 1157 | |
| 1158 | pub fn send_protocol(&mut self, payload: &[u8]) -> Result<Vec<u8>> { |
| 1159 | { |
| 1160 | let _phase = timing::phase("postgres.protocol.ensure_started"); |
| 1161 | self.start_protocol()?; |
| 1162 | } |
| 1163 | if payload.is_empty() { |
| 1164 | return Ok(Vec::new()); |
| 1165 | } |
| 1166 | self.send_protocol_inner(payload) |
| 1167 | } |
| 1168 | |
| 1169 | pub(crate) fn attach_protocol_stream<S>(&mut self, stream: S) -> Result<()> |
| 1170 | where |
no test coverage detected