(mut buf: Cursor)
| 811 | } |
| 812 | |
| 813 | fn decode_parse(mut buf: Cursor) -> Result<FrontendMessage, io::Error> { |
| 814 | let name = buf.read_cstr()?; |
| 815 | let sql = buf.read_cstr()?; |
| 816 | |
| 817 | let mut param_types = vec![]; |
| 818 | for _ in 0..buf.read_i16()? { |
| 819 | param_types.push(buf.read_u32()?); |
| 820 | } |
| 821 | |
| 822 | Ok(FrontendMessage::Parse { |
| 823 | name: name.into(), |
| 824 | sql: sql.into(), |
| 825 | param_types, |
| 826 | }) |
| 827 | } |
| 828 | |
| 829 | fn decode_close(mut buf: Cursor) -> Result<FrontendMessage, io::Error> { |
| 830 | match buf.read_byte()? { |