use crate::io::AsyncStreamExt;
use crate::protocol::message::{BackendMessage, BackendMessageFormat};
use crate::protocol::ServerContext;
use sqlx_core::Error;
#[derive(Debug)]
pub struct UpdateResponse {
pub rows_affected: i32,
}
impl BackendMessage for UpdateResponse {
const FORMAT: BackendMessageFormat = BackendMessageFormat::UpdateResponse;
async fn decode_body<S: AsyncStreamExt>(
stream: &mut S,
_: ServerContext,
) -> Result<Self, Error> {
let rows_affected = stream.read_i32().await?;
Ok(Self { rows_affected })
}
}