(
&self,
length: usize,
reader: &mut BufferReader<'_>,
name: MessageName,
)
| 150 | } |
| 151 | |
| 152 | fn parse_copy_message( |
| 153 | &self, |
| 154 | length: usize, |
| 155 | reader: &mut BufferReader<'_>, |
| 156 | name: MessageName, |
| 157 | ) -> Result<BackendMessage> { |
| 158 | let is_binary = reader.byte()? != 0; |
| 159 | let column_count = reader.int16()? as usize; |
| 160 | let mut column_types = Vec::with_capacity(column_count); |
| 161 | for _ in 0..column_count { |
| 162 | column_types.push(reader.int16()?); |
| 163 | } |
| 164 | Ok(BackendMessage::CopyResponse(CopyResponse { |
| 165 | length, |
| 166 | name, |
| 167 | binary: is_binary, |
| 168 | column_types, |
| 169 | })) |
| 170 | } |
| 171 | |
| 172 | fn parse_notification( |
| 173 | &self, |
no test coverage detected