Crate acto

Source
Expand description

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.