#[test]
fn tokio_poll_with_compat() {
i_slint_backend_testing::init_integration_test_with_mock_time();
use std::io::Write;
let listener = std::net::TcpListener::bind("127.0.0.1:0").unwrap();
let local_addr = listener.local_addr().unwrap();
let server = std::thread::spawn(move || {
let mut stream = listener.incoming().next().unwrap().unwrap();
stream.write("Hello World".as_bytes()).unwrap();
});
let slint_future = async move {
for _ in 0..1000 {
tokio::task::consume_budget().await;
}
use tokio::io::AsyncReadExt;
let mut stream = tokio::net::TcpStream::connect(local_addr).await.unwrap();
let mut data = Vec::new();
stream.read_to_end(&mut data).await.unwrap();
assert_eq!(data, "Hello World".as_bytes());
slint::quit_event_loop().unwrap();
};
slint::spawn_local(async_compat::Compat::new(slint_future)).unwrap();
slint::run_event_loop_until_quit().unwrap();
server.join().unwrap();
}