1use futures::stream::StreamExt;
4use netlink_packet_core::{NetlinkMessage, NLM_F_ACK, NLM_F_REQUEST};
5use netlink_packet_route::{rule::RuleMessage, RouteNetlinkMessage};
6
7use crate::{try_nl, Error, Handle};
8
9#[derive(Debug, Clone)]
10pub struct RuleDelRequest {
11 handle: Handle,
12 message: RuleMessage,
13}
14
15impl RuleDelRequest {
16 pub(crate) fn new(handle: Handle, message: RuleMessage) -> Self {
17 RuleDelRequest { handle, message }
18 }
19
20 pub async fn execute(self) -> Result<(), Error> {
22 let RuleDelRequest {
23 mut handle,
24 message,
25 } = self;
26
27 let mut req =
28 NetlinkMessage::from(RouteNetlinkMessage::DelRule(message));
29 req.header.flags = NLM_F_REQUEST | NLM_F_ACK;
30 let mut response = handle.request(req)?;
31 while let Some(msg) = response.next().await {
32 try_nl!(msg);
33 }
34 Ok(())
35 }
36
37 pub fn message_mut(&mut self) -> &mut RuleMessage {
38 &mut self.message
39 }
40}