Crate acto 

Runtime-agnostic actor library for Rust

Currently supports tokio for execution. Please refer to AcTokio for example usage.

Actors combine well with sharing immutable snapshots, like futures-signals.

Modules

variable

Structs

AcTokio

Owned handle to an AcTokioRuntime.

AcTokioRuntime

An ActoRuntime based on tokio::runtime and tokio::sync::mpsc queues.

ActoAborted

This error is returned when an actor has been aborted.

ActoCell

The confines of an actor, and the engine that makes it work.

ActoId

Every actor has an ID that is generated by acto, independent of the [ActoRuntime] used.

ActoRef

A handle for sending messages to an actor.

MappedActoHandle

An ActoHandle that results from ActoHandle::map.

SupervisionRef

A package of an actor’s ActoRef and ActoHandle.

TokioJoinHandle

Enums

ActoInput

Actor input as received with [ActoCell::recv].

ActoMsgSuper

A filtered variant of ActoInput that omits NoMoreSenders.

PanicOrAbort

Traits

ActoHandle

A handle for aborting or joining a running actor.

ActoRuntime

For implementors: the interface of a runtime for operating actors.

MailboxSize

This trait is implemented by ActoRuntimes that allow customization of the mailbox size.

PanicInfo

Receiver

A named closure for receiving messages at a given actor.

Sender

A named closure for sending messages to a given actor.