pub type RefSignalIterator<'a, R, E> = SignalIterator<&'a mut SignalDelivery<R, E>, E>;
Expand description

A signal iterator which takes a mutable reference to a SignalDelivery instance.

Aliased Type§

struct RefSignalIterator<'a, R, E> { /* private fields */ }

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.