aktoro-rs/aktoro

[WIP] Yet another Actor framework for Rust.

aktoro's Issues

Documentation

The crates need an overall cleanup of their documentation.

Channel errors: add "kind" and "into_kind" methods

Remove `Spawned::try_send_msg` and use events in `Context` instead of messages

Spawn::try_send_action should be used instead.

Add logs (trace, debug, etc.)

Documentation

• aktoro-raw:
  • action::*
  • actor::*
  • channel::*
  • context::*
  • control::*
  • event::*
  • message::*
  • runtime::*
  • spawned::*
  • update::*
• aktoro-channel:
  • builder::*
  • channel::*
  • counter::*
  • error::*
  • message::*
  • notify::*
  • queue::*
  • receiver::*
  • sender::*
• aktoro-context:
  • action::*
  • channel::*
  • context::*
  • control::*
  • event::*
  • message::*
  • respond::*
  • update::*
• aktoro-runtime:
  • actor::*
  • error::*
  • runtime::*

Sub-actors

Actors should be able to spawn other actors.

Open TCP/UDP stream/socket from actor

Actors need to be able to open new TCP/UDP streams/sockets.

TCP/UDP streams/sockets

• #11
• #8
• #9
• #15

Blocked by rust-lang/rust#61872.

NOTE: TCP and UDP streams/sockets have been released in v0.1.0-alpha.3 but in a useless state (they can't be opened by actors directly and actors can't send or receive data to/from them).

Context: stop and kill

• Context<A: Actor>::stop(&mut self): alias for Context<A: Actor, S: Actor::Status>::set_status(&mut self, status: S) where status == S::stopped()
• Context<A: Actor>::kill(&mut self): alias for Context<A: Actor, S: Actor::Status>::set_status(&mut self, status: S) where status == S::dead()

Blocking (I/O-wise) future execution

Context: error, stop_error and kill_error

• Context<A: Actor>::error(&mut self, err: A::Error): emits an error to the Spawned handle
• Context<A: Actor>::stop_error(&mut self, err: A::Error): emits an error to the Spanwed handle and stop the actor gracefully
• Context<A: Actor>::kill_error(&mut self, err: A::Error): kills the actor and return the error to the Spawned handle

Close streams actors are subscribed to

Actors that are subscribed to a stream or receiving data from an AsyncRead should be able to unsubscribe from them (returning the original stream) or to close them.

Tests

TODO: write a list of the tests wanted

Allow to poll the runtime while still being able to spawn new actors

The runtime's wait method might be removed and replaced with a Stream implementation.

Forward streams

Actors should be able to open a stream and receive new data from them as messages.

This is useful, for example, when listening for new TCP connections.

HTTP client and server library

There should be an HTTP client and server library using aktoro and made to be used with it.

Better naming

• Context::wait could be understood as if the context is waiting for the future to yield before handling other futures and messages.
• Context::blocking_wait would then make no sense.
• Context::exec and Context::blocking_exec could be renamed and used as wait and blocking_name's new names.

Await futures

Actors should be able to await a future.

This is useful, for example, when trying to open a new TCP connection.