Struct FnActor 

pub struct FnActor { /* private fields */ }

An actor that runs an async function per input.

Implementations

impl FnActor

pub fn new(address: Address, f: ActorFn) -> Self

An actor at address running f for every input.

pub fn invokable<F, Fut>(f: F) -> ActorFactory

where F: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, String>> + Send + 'static,

The factory of an invokable async function: on start it runs f on the invoke’s parameters, and its result is the child’s done data (done.invoke.<id>); an error is a failure, subject to vt:restart.

pub fn handler<F, Fut>(f: F) -> ActorFn

where F: Fn(Event) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Option<Value>, String>> + Send + 'static,

A request handler for a stateless worker: f gets each event and its result, when there is one, is sent back to the event’s origin as vt:reply.

Trait Implementations

impl Actor for FnActor

fn address(&self) -> &Address

The actor’s address.

fn turn(&mut self, input: ActorInput) -> Turn

Handles one input.

impl Debug for FnActor

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

Formats the value using the given formatter.