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
24
25
26
27
28
29
30
31
32

//! Serialization framework. akka.net: `src/core/Akka/Serialization/`.
//!
//! A `Serializer` is a pluggable codec identified by a numeric id. The
//! registry maps both rust `TypeId` and serializer id to concrete codecs.

mod json;
mod registry;
mod traits;

pub use json::JsonSerializer;
pub use registry::SerializationRegistry;
pub use traits::{Serializer, SerializerError};

#[cfg(test)]
mod tests {
    use super::*;
    use serde::{Deserialize, Serialize};

    #[derive(Debug, Serialize, Deserialize, PartialEq)]
    struct Greeting {
        who: String,
    }

    #[test]
    fn json_roundtrip() {
        let reg = SerializationRegistry::default();
        reg.register(JsonSerializer::<Greeting>::new(1));
        let out = reg.to_bytes(&Greeting { who: "world".into() }).expect("serialize");
        let back: Greeting = reg.from_bytes(&out).expect("deserialize");
        assert_eq!(back.who, "world");
    }
}