Read a response and return Ok(()) if it was a [`Response::Ok`].
(
socket: &mut SocketStream,
error: MigratableError,
)
| 828 | |
| 829 | /// Read a response and return Ok(()) if it was a [`Response::Ok`]. |
| 830 | pub(crate) fn expect_ok_response( |
| 831 | socket: &mut SocketStream, |
| 832 | error: MigratableError, |
| 833 | ) -> Result<(), MigratableError> { |
| 834 | Response::read_from(socket)? |
| 835 | .ok_or_abandon(socket, error) |
| 836 | .map(|_| ()) |
| 837 | } |
| 838 | |
| 839 | /// Send a request and validate that the peer responds with OK. |
| 840 | pub(crate) fn send_request_expect_ok( |
no test coverage detected