1// Copyright © SixtyFPS GmbH <info@slint.dev>
2// SPDX-License-Identifier: GPL-3.0-only OR LicenseRef-Slint-Royalty-free-2.0 OR LicenseRef-Slint-Software-3.0
3
4#[test]
5fn tokio_poll_with_compat() {
6 i_slint_backend_testing::init_integration_test_with_mock_time();
7 use std::io::Write;
8
9 let listener = std::net::TcpListener::bind("127.0.0.1:0").unwrap();
10 let local_addr = listener.local_addr().unwrap();
11 let server = std::thread::spawn(move || {
12 let mut stream = listener.incoming().next().unwrap().unwrap();
13 stream.write("Hello World".as_bytes()).unwrap();
14 });
15
16 let slint_future = async move {
17 for _ in 0..1000 {
18 tokio::task::consume_budget().await;
19 }
20
21 use tokio::io::AsyncReadExt;
22 let mut stream = tokio::net::TcpStream::connect(local_addr).await.unwrap();
23 let mut data = Vec::new();
24 stream.read_to_end(&mut data).await.unwrap();
25 assert_eq!(data, "Hello World".as_bytes());
26 slint::quit_event_loop().unwrap();
27 };
28
29 slint::spawn_local(async_compat::Compat::new(slint_future)).unwrap();
30
31 slint::run_event_loop_until_quit().unwrap();
32
33 server.join().unwrap();
34}
35