Struct kabuki::ActorFn

pub struct ActorFn<F, T> { /* fields omitted */ }

An actor implemented by a closure.

Trait Implementations

impl<F, T, U> Actor for ActorFn<F, T> where F: FnMut(T) -> U, U: IntoFuture

type Request = T

The message sent to the actor

type Response = U::Item

The response sent back from the actor

type Error = U::Error

The response error

type Future = U

The internal response future. This will remain on the actor's task and will be polled to completion before being sent back to the caller.

fn call(&mut self, req: Self::Request) -> Self::Future

Process an inbound message and return a response.

fn poll(&mut self, state: ActorState) -> Async<()>

Poll the Actor to see if it has completed processing.

fn poll_ready(&mut self) -> Async<()>

Indicates that the actor is ready to process the next inbox message