Struct Evermore 

pub struct Evermore<E, S, D, F>
where
    S: Future<Output = ()> + Send,
    D: Clone,
    F: Unpin + Factory<D>,
{ /* private fields */ }

An graceful shutdown enabled repeating asynchronous task runner.

Implementations

impl<E, S, D, F> Evermore<E, S, D, F>

where E: Error, S: Future<Output = ()> + Send, D: Clone, F: Unpin + Factory<D>, <F as Factory<D>>::Future: TryFuture<Error = E> + Unpin,

pub fn new(signal: S, worker_count: usize, data: D, factory: F) -> Self

Examples found in repository

examples/simple.rs (lines 7-9)

fn main() {
    let _ = Evermore::new(async {}, 4, Data::default(), |worker| {
        Box::pin(task(worker))
    });
}

Trait Implementations

impl<E, S, D, F> Future for Evermore<E, S, D, F>

where E: Error, S: Future<Output = ()> + Send, D: Clone, F: Unpin + Factory<D>, <F as Factory<D>>::Future: TryFuture<Error = E>,

type Output = ()

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'pin, E, S, D, F> Unpin for Evermore<E, S, D, F>

where S: Future<Output = ()> + Send, D: Clone, F: Unpin + Factory<D>, __Evermore<'pin, E, S, D, F>: Unpin,