/// receives next RPC call with RPC ID
receives next RPC call with RPC ID
receives next RPC call with RPC ID
fn receive(&self) -> Result<(RPCHeader, Vec<u8>), RPCError> {
        let mut req_data = self.rx.recv().unwrap(); // TODO: handle error more gracefully
        let (hdr, data) = unsafe { decode::<RPCHeader>(&mut req_data) }.unwrap();
        Ok((*hdr, data.to_vec()))
    }
fn receive ( & self ) -> Result < ( RPCHeader , Vec < u8 > ) , RPCError > { let mut req_data = self . rx . recv ( ) . unwrap ( ) ; // TODO: handle error more gracefully let ( hdr , data ) = unsafe { decode :: < RPCHeader > ( & mut req_data ) } . unwrap ( ) ; Ok ( ( * hdr , data . to_vec ( ) ) ) }
receives next RPC call with RPC ID
receives next RPC call with RPC ID
&self