Struct Worker 

pub struct Worker<J> { /* private fields */ }

Implementations

impl<J> Worker<J>

pub fn new(name: &str, buf: usize) -> Self

pub fn with_on_start<F, Fut>(self, task: F) -> Self

where F: FnOnce() -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + Sync + 'static,

pub fn with_on_exit<F, Fut>(self, task: F) -> Self

where F: FnOnce() -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + Sync + 'static,

pub fn with_graceful(self, graceful: bool) -> Self

pub fn with_trigger( self, trigger: (Arc<Sender<J>>, Arc<Mutex<Receiver<J>>>), ) -> Self

pub fn get_sender(&self) -> Arc<Sender<J>>

pub async fn send(&self, job: J) -> Result<(), SendError<J>>

pub fn name(&self) -> String

pub async fn count(&self) -> usize

pub async fn stop(&self) -> Result<(), SendError<()>>

pub async fn run<F, Fut>(&self, how: F)

where F: FnMut(J) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static, J: Send + Sync + 'static,

Trait Implementations

impl<J: Clone> Clone for Worker<J>

fn clone(&self) -> Worker<J>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.