Struct Worker

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

Implementations

impl<J> Worker<J>

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

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

pub fn with_trigger(self, trigger: (Sender<J>, 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: Fn(J) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + Sync + 'static, J: Send + Sync + 'static,