Struct rabble::TcpServerHandler

pub struct TcpServerHandler<C, S> where C: ConnectionHandler<ClientMsg=S::Msg>, S: Serialize { /* fields omitted */ }

A service handler for an async TCP server

Methods

impl<C, S> TcpServerHandler<C, S> where C: ConnectionHandler<ClientMsg=S::Msg>, S: Serialize

fn new(pid: Pid,
       addr: &str,
       request_timeout: usize,
       connection_timeout: Option<usize>)
       -> TcpServerHandler<C, S>

Create a new TcpServerHandler

Bind to addr and close a connection that hasn't received a message in connection_timeout ms. Note that the connection timeout is optional.

Every request with a CorrelationId is also tracked with a timer. This request_timeout is not optional as every request can potentially fail, or be delayed indefinitely.

Trait Implementations

impl<C, S> ServiceHandler<C::Msg> for TcpServerHandler<C, S> where C: ConnectionHandler<ClientMsg=S::Msg>, S: Serialize

fn init(&mut self, registrar: &Registrar, _node: &Node<C::Msg>) -> Result<()>

Initialize the state of the handler: Register timers and tcp listen socket

fn handle_notification(&mut self,
                       node: &Node<C::Msg>,
                       notification: Notification,
                       registrar: &Registrar)
                       -> Result<()>

Handle any poll notifications

fn handle_envelope(&mut self,
                   node: &Node<C::Msg>,
                   envelope: Envelope<C::Msg>,
                   _registrar: &Registrar)
                   -> Result<()>

Handle an envelope from a process or service