Trait paxos::Reactor
[−]
[src]
pub trait Reactor: Debug + Clone { type Peer: ToSocketAddrs; type Message: Serialize + DeserializeOwned; fn receive(
&mut self,
at: SystemTime,
from: Self::Peer,
msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>; fn tick(&mut self, _at: SystemTime) -> Vec<(Self::Peer, Self::Message)> { ... } }
Associated Types
type Peer: ToSocketAddrs
type Message: Serialize + DeserializeOwned
Required Methods
fn receive(
&mut self,
at: SystemTime,
from: Self::Peer,
msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>
&mut self,
at: SystemTime,
from: Self::Peer,
msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>