pub fn finish<S>(mut self, spawner: S) -> Server<S>
    where
        S: Clone + Spawn + Send + 'static,
    {
        let logger = self.logger.new(o!("server" => self.bind_addr.to_string()));
        info!(logger, "Starts RPC server");
        let handlers = mem::replace(&mut self.handlers, MessageHandlers(HashMap::new()));
        Server {
            listener: Listener::Binding(TcpListener::bind(self.bind_addr)),
            logger,
            spawner,
            assigner: Assigner::new(handlers),
            channel_options: self.channel_options.clone(),
            metrics: ServerMetrics::new(self.metrics.clone(), self.handlers_metrics.clone()),
        }
    }
/// Returns the resulting RPC server.
Returns the resulting RPC server.
Returns the resulting RPC server .
pub fn finish<S>(mut self, spawner: S) -> Server<S>
    where
        S: Clone + Spawn + Send + 'static,
    {
        let logger = self.logger.new(o!("server" => self.bind_addr.to_string()));
        info!(logger, "Starts RPC server");
        let handlers = mem::replace(&mut self.handlers, MessageHandlers(HashMap::new()));
        Server {
            listener: Listener::Binding(TcpListener::bind(self.bind_addr)),
            logger,
            spawner,
            assigner: Assigner::new(handlers),
            channel_options: self.channel_options.clone(),
            metrics: ServerMetrics::new(self.metrics.clone(), self.handlers_metrics.clone()),
        }
    }
pub fn finish < S > ( mut self , spawner : S ) -> Server < S > where S : Clone + Spawn + Send + ' static , { let logger = self . logger . new ( o ! ( " " self bind_addr to_string ( ) ) ) ; info ! ( logger " " ) ; let handlers = mem :: replace ( & mut self . handlers , MessageHandlers ( HashMap :: new ( ) ) ) ; Server { listener : Listener :: Binding ( TcpListener :: bind ( self . bind_addr ) ) , logger , spawner , assigner : Assigner :: new ( handlers ) , channel_options : self . channel_options . clone ( ) , metrics : ServerMetrics :: new ( self . metrics . clone ( ) , self . handlers_metrics . clone ( ) ) , } }
Returns the resulting RPC server.
Returns the resulting RPC server .
mut self
spawner
S
mut self
spawner
S