/// Return the number of transactions the server processed since creating
/// this stub instance.
Return the number of transactions the server processed since creating
this stub instance.
Return the number of transactions the server processed since creating this stub instance .
pub fn transaction_count(&mut self) -> u64 {
        // Wait for at least one EntryInfo.
        let mut done = false;
        while !done {
            let resp = self.recv_response().expect("recv response");
            if let &Response::EntryInfo(_) = &resp {
                done = true;
            }
            self.process_response(resp);
        }
        // Then take the rest.
        self.socket.set_nonblocking(true).expect("set nonblocking");
        loop {
            match self.recv_response() {
                Err(_) => break,
                Ok(resp) => self.process_response(resp),
            }
        }
        self.socket.set_nonblocking(false).expect("set blocking");
        self.num_events
    }
pub fn transaction_count ( & mut self ) -> u64 { // Wait for at least one EntryInfo. let mut done = false ; while ! done { let resp = self . recv_response ( ) . expect ( " " ) ; if let & Response :: EntryInfo ( _ ) = & resp { done = true ; } self . process_response ( resp ) ; } // Then take the rest. self . socket . set_nonblocking ( true ) . expect ( " " ) ; loop { match self . recv_response ( ) { Err ( _ ) => break , Ok ( resp ) => self . process_response ( resp ) , } } self . socket . set_nonblocking ( false ) . expect ( " " ) ; self . num_events }
Return the number of transactions the server processed since creating
this stub instance.
Return the number of transactions the server processed since creating this stub instance .
&mut self