use futures::stream::StreamExt;
use crate::{
packet::{AddressMessage, NetlinkMessage, RtnlMessage, NLM_F_ACK, NLM_F_REQUEST},
try_nl,
Error,
Handle,
};
pub struct AddressDelRequest {
handle: Handle,
message: AddressMessage,
}
impl AddressDelRequest {
pub(crate) fn new(handle: Handle, message: AddressMessage) -> Self {
AddressDelRequest { handle, message }
}
pub async fn execute(self) -> Result<(), Error> {
let AddressDelRequest {
mut handle,
message,
} = self;
let mut req = NetlinkMessage::from(RtnlMessage::DelAddress(message));
req.header.flags = NLM_F_REQUEST | NLM_F_ACK;
let mut response = handle.request(req)?;
while let Some(msg) = response.next().await {
try_nl!(msg);
}
Ok(())
}
pub fn message_mut(&mut self) -> &mut AddressMessage {
&mut self.message
}
}