(stream: &mut TcpStream)
| 2058 | } |
| 2059 | |
| 2060 | fn read_android_console_response(stream: &mut TcpStream) -> Result<String, AppError> { |
| 2061 | let mut response = String::new(); |
| 2062 | let mut buffer = [0u8; 1024]; |
| 2063 | loop { |
| 2064 | let bytes_read = stream.read(&mut buffer).map_err(|error| { |
| 2065 | AppError::native(format!("Android emulator console read failed: {error}")) |
| 2066 | })?; |
| 2067 | if bytes_read == 0 { |
| 2068 | return Err(AppError::native( |
| 2069 | "Android emulator console closed the connection.", |
| 2070 | )); |
| 2071 | } |
| 2072 | response.push_str(&String::from_utf8_lossy(&buffer[..bytes_read])); |
| 2073 | if android_console_response_complete(&response) { |
| 2074 | return Ok(response); |
| 2075 | } |
| 2076 | } |
| 2077 | } |
| 2078 | |
| 2079 | fn android_console_response_complete(response: &str) -> bool { |
| 2080 | response |
no test coverage detected