Struct Worker

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

Represents a generic Worker that can be in many different states

Implementations

impl<T> Worker<T>

pub fn new(id: WorkerId, state: T) -> Self

Create a new worker instance

pub fn inner(&self) -> &T

Get the inner state

pub fn id(&self) -> &WorkerId

Get the worker id

impl Worker<Context>

pub fn emit(&self, event: Event) -> bool

Allows workers to emit events

impl<S, P> Worker<Ready<S, P>>

pub fn on_event<F: Fn(Worker<Event>) + Send + Sync + 'static>( self, f: F, ) -> Self

Add an event handler to the worker

pub fn run<Req, Res, Ctx>(self) -> Runnable

where S: Service<Request<Req, Ctx>, Response = Res> + Send + 'static, P: Backend<Request<Req, Ctx>, Res> + 'static, Req: Send + 'static + Sync, S::Future: Send, S::Response: 'static + Send + Sync + Serialize, S::Error: Send + Sync + 'static + Into<BoxDynError>, P::Stream: Unpin + Send + 'static, P::Layer: Layer<S>, <P::Layer as Layer<S>>::Service: Service<Request<Req, Ctx>, Response = Res> + Send, <<P::Layer as Layer<S>>::Service as Service<Request<Req, Ctx>>>::Future: Send, <<P::Layer as Layer<S>>::Service as Service<Request<Req, Ctx>>>::Error: Send + Into<BoxDynError> + Sync, Ctx: Send + 'static + Sync, Res: 'static,

Start a worker

Trait Implementations

impl<T: Clone> Clone for Worker<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Worker<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Deref for Worker<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for Worker<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Display for Worker<Event>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Req, Ctx> FromRequest<Request<Req, Ctx>> for Worker<Context>

fn from_request(req: &Request<Req, Ctx>) -> Result<Self, Error>

Perform the extraction.

impl<T> Serialize for Worker<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.