actor12 0.0.9

A lightweight actor framework for Rust with async support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use std::error::Error;

use crate::channel::{ActorChannel, ActorSender};
use crate::link::ActorLike;

pub type ActorSendError<A> = <<<A as ActorLike>::Channel as ActorChannel>::Sender as ActorSender<
	<<A as ActorLike>::Channel as ActorChannel>::Message,
>>::Error;

#[derive(thiserror::Error, Debug)]
pub enum ActorError {
	#[error("Dynamic send error")]
	DynSendError(),

	#[error("Actor is already dead")]
	Dead,

	#[error("Reply taken")]
	ReplyTaken,

	#[error("Async reply")]
	AsyncReply,
}

pub trait FromError<E> {
	fn from_err(err: E) -> Self
	where
		Self: Sized;
}

impl<T, E> FromError<E> for anyhow::Result<T>
where
	T: Send + Sync + 'static,
	E: Error + Send + Sync + 'static,
{
	fn from_err(err: E) -> Self {
		Err(anyhow::Error::new(err))
	}
}