nodo_nng 0.18.5

Remote message passing with NNG for NODO
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

// Copyright 2023 David Weikersdorfer

use core::marker::PhantomData;
use nodo::core::{BinaryFormat, Schema};
use serde::{Deserialize, Serialize};

pub struct Bincode<T>(PhantomData<T>);

impl<T> Default for Bincode<T> {
    fn default() -> Self {
        Self(PhantomData)
    }
}

impl<T> BinaryFormat<T> for Bincode<T>
where
    T: Serialize + for<'a> Deserialize<'a>,
{
    fn schema(&self) -> Schema {
        Schema {
            name: core::any::type_name::<T>().to_string(),
            encoding: String::from("bincode"),
        }
    }

    fn serialize(&mut self, data: &T) -> eyre::Result<Vec<u8>> {
        Ok(bincode::serialize(data)?)
    }

    fn deserialize(&mut self, buffer: &[u8]) -> eyre::Result<T> {
        Ok(bincode::deserialize(&buffer)?)
    }
}