pub struct SignalIterator<SD, E: Exfiltrator> { /* private fields */ }
Available on non-Windows and crate feature iterator only.
Expand description

An infinite iterator of received signals.

Implementations§

source§

impl<SD, E: Exfiltrator> SignalIterator<SD, E>

source

pub fn new<R>(signals: SD) -> Selfwhere SD: BorrowMut<SignalDelivery<R, E>>, R: 'static + AsRawFd + Send + Sync,

Create a new infinite iterator for signals registered with the passed in SignalDelivery instance.

source

pub fn poll_signal<R, F>( &mut self, has_signals: &mut F ) -> PollResult<E::Output>where SD: BorrowMut<SignalDelivery<R, E>>, R: 'static + AsRawFd + Send + Sync, F: FnMut(&mut R) -> Result<bool, Error>,

Return a signal if there is one or tell the caller that there is none at the moment.

You have to pass in a callback which checks the underlying reading end of the pipe if there may be any pending signals. This callback may or may not block. If the callback returns true this method will try to fetch the next signal and return it as a PollResult::Signal. If the callback returns false the method will return PollResult::Pending and assume it will be called again at a later point in time. The callback may be called any number of times by this function.

If the iterator was closed by the close method of the associated Handle this method will return PollResult::Closed.

source

pub fn handle<R>(&self) -> Handlewhere SD: Borrow<SignalDelivery<R, E>>, R: 'static + AsRawFd + Send + Sync,

Get a shareable Handle for this instance.

This can be used to add further signals or terminate the whole signal iteration using the close method.

Auto Trait Implementations§

§

impl<SD, E> RefUnwindSafe for SignalIterator<SD, E>where E: RefUnwindSafe, SD: RefUnwindSafe, <E as Exfiltrator>::Storage: RefUnwindSafe,

§

impl<SD, E> Send for SignalIterator<SD, E>where SD: Send,

§

impl<SD, E> Sync for SignalIterator<SD, E>where SD: Sync,

§

impl<SD, E> Unpin for SignalIterator<SD, E>where SD: Unpin,

§

impl<SD, E> UnwindSafe for SignalIterator<SD, E>where E: RefUnwindSafe, SD: UnwindSafe, <E as Exfiltrator>::Storage: RefUnwindSafe,

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.