(
&self,
length: usize,
reader: &mut BufferReader<'_>,
)
| 119 | } |
| 120 | |
| 121 | fn parse_ready_for_query( |
| 122 | &self, |
| 123 | length: usize, |
| 124 | reader: &mut BufferReader<'_>, |
| 125 | ) -> Result<BackendMessage> { |
| 126 | let status = reader.string(1)?; |
| 127 | ensure!(status.len() == 1, "invalid readyForQuery status"); |
| 128 | Ok(BackendMessage::ReadyForQuery(ReadyForQueryMessage { |
| 129 | length, |
| 130 | status: status.as_bytes()[0], |
| 131 | })) |
| 132 | } |
| 133 | |
| 134 | fn parse_command_complete( |
| 135 | &self, |