Struct OwnedEventStream 

pub struct OwnedEventStream<P: EventSource> { /* private fields */ }

A stream of events that owns the underlying connection.

Created by Connection::into_events(). Use EventSubscription via Connection::subscribe() if you need to retain access to the connection.

Example

use nlink::netlink::{Connection, SELinux};
use tokio_stream::StreamExt;

let conn = Connection::<SELinux>::new()?;
let mut stream = conn.into_events();

while let Some(event) = stream.try_next().await? {
    println!("{:?}", event);
}

// Recover the connection if needed
let conn = stream.into_connection();

Implementations

impl<P: EventSource> OwnedEventStream<P>

pub fn connection(&self) -> &Connection<P>

Get a reference to the underlying connection.

pub fn into_connection(self) -> Connection<P>

Consume this stream and return the underlying connection.

Trait Implementations

impl<P: EventSource> Stream for OwnedEventStream<P>

type Item = Result<<P as EventSource>::Event, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<P: EventSource> Unpin for OwnedEventStream<P>