Trait deterministic::Reactor

pub trait Reactor: Sized {
    type Peer: ToSocketAddrs;
    type Message: Serialize + DeserializeOwned;
    type Config;
    type Error;

    const PERIODIC_INTERVAL: Option<Duration> = None;

    fn start(config: Self::Config) -> Result<Self, Self::Error>;
    fn receive(
        &mut self,
        from: Self::Peer,
        msg: Self::Message
    ) -> Vec<(Self::Peer, Self::Message)>;

    fn periodic(&mut self) -> Vec<(Self::Peer, Self::Message)> { ... }
}

A trait for building networked systems that can be plugged into simulated networks and partition tested in accelerated time.

Required Associated Types

type Peer: ToSocketAddrs

type Message: Serialize + DeserializeOwned

type Config

type Error

Provided Associated Constants

const PERIODIC_INTERVAL: Option<Duration> = None

Required Methods

fn start(config: Self::Config) -> Result<Self, Self::Error>

fn receive(
    &mut self,
    from: Self::Peer,
    msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>

Provided Methods

fn periodic(&mut self) -> Vec<(Self::Peer, Self::Message)>

Implementors