atomr-core 0.1.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Serializer traits. akka.net: `Serialization/Serializer.cs`.

use thiserror::Error;

#[derive(Debug, Error)]
pub enum SerializerError {
    #[error("no serializer registered for type")]
    NotRegistered,
    #[error("serializer id {0} not known")]
    UnknownId(u32),
    #[error("encode error: {0}")]
    Encode(String),
    #[error("decode error: {0}")]
    Decode(String),
}

pub trait Serializer<T>: Send + Sync {
    fn identifier(&self) -> u32;
    fn manifest(&self) -> &'static str;
    fn to_bytes(&self, value: &T) -> Result<Vec<u8>, SerializerError>;
    #[allow(clippy::wrong_self_convention)]
    fn from_bytes(&self, bytes: &[u8]) -> Result<T, SerializerError>;
}