pub fn request(
        &mut self,
        message: NetlinkMessage,
    ) -> impl Stream<Item = NetlinkMessage, Error = NetlinkIpError> {
        let (tx, rx) = unbounded::<NetlinkMessage>();
        // Ignore the result. If this failed, `tx` will be dropped when this funtion returns, and
        // polling rx with fail, carrying the error.
        debug!("handle: forwarding new request to connection");
        let _ = UnboundedSender::unbounded_send(&self.requests_tx, (tx, message));
        rx.map_err(|()| {
            error!("could not forward new request to connection: the connection is closed");
            NetlinkIpError::ConnectionClosed
        })
    }
/// Send a new request and get the response as a stream of messages. Note that some messages
/// are not part of the response stream:
///
/// - **acknowledgements**: when an acknowledgement is received, the stream is closed
/// - **end of dump messages**: similarly, upon receiving an "end of dump" message, the stream is
/// closed
Send a new request and get the response as a stream of messages. Note that some messages
are not part of the response stream.

acknowledgements**: when an acknowledgement is received, the stream is closed
end of dump messages**: similarly, upon receiving an "end of dump" message, the stream is
closed
Send a new request and get the response as a stream of messages . Note that some messages are not part of the response stream . acknowledgements ** : when an acknowledgement is received the stream is closed end of dump messages ** : similarly upon receiving an " end of dump " message the stream is closed
pub fn request(
        &mut self,
        message: NetlinkMessage,
    ) -> impl Stream<Item = NetlinkMessage, Error = NetlinkIpError> {
        let (tx, rx) = unbounded::<NetlinkMessage>();
        // Ignore the result. If this failed, `tx` will be dropped when this funtion returns, and
        // polling rx with fail, carrying the error.
        debug!("handle: forwarding new request to connection");
        let _ = UnboundedSender::unbounded_send(&self.requests_tx, (tx, message));
        rx.map_err(|()| {
            error!("could not forward new request to connection: the connection is closed");
            NetlinkIpError::ConnectionClosed
        })
    }
pub fn request ( & mut self , message : NetlinkMessage , ) -> impl Stream < Item = NetlinkMessage , Error = NetlinkIpError > { let ( tx , rx ) = unbounded :: < NetlinkMessage > ( ) ; // Ignore the result. If this failed, `tx` will be dropped when this funtion returns, and // polling rx with fail, carrying the error. debug ! ( " " ) ; let _ = UnboundedSender :: unbounded_send ( & self . requests_tx , ( tx , message ) ) ; rx . map_err ( | ( ) | { error ! ( " " ) ; NetlinkIpError :: ConnectionClosed } ) }
Send a new request and get the response as a stream of messages.
Send a new request and get the response as a stream of messages .
&mut self
message
NetlinkMessage
&mut self
message
NetlinkMessage