pub fn serve(self, socket: SrvStream) -> impl Future<Item = (), Error = HandlerError> {
        let mgr_sender = self.state.borrow().mgr_sender.clone();
        self.handshake(socket)
            .and_then(|socket| SrvHandler::new(socket, mgr_sender))
    }
/// Serve the client from the given framed socket stream.
Serve the client from the given framed socket stream.
Serve the client from the given framed socket stream .
pub fn serve(self, socket: SrvStream) -> impl Future<Item = (), Error = HandlerError> {
        let mgr_sender = self.state.borrow().mgr_sender.clone();
        self.handshake(socket)
            .and_then(|socket| SrvHandler::new(socket, mgr_sender))
    }
pub fn serve ( self , socket : SrvStream ) -> impl Future < Item = ( ) , Error = HandlerError > { let mgr_sender = self . state . borrow ( ) . mgr_sender . clone ( ) ; self . handshake ( socket ) . and_then ( | socket | SrvHandler :: new ( socket , mgr_sender ) ) }
Serve the client from the given framed socket stream.
Serve the client from the given framed socket stream .
self
socket
SrvStream
self
socket
SrvStream