Skip to content

Commit 1ce2631

Browse files
committed
WIP: threaded fragment tests
1 parent e47a727 commit 1ce2631

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/platform/test.rs

+7-1
Original file line numberDiff line numberDiff line change
@@ -177,9 +177,15 @@ fn with_n_fds(n: usize, size: usize) {
177177
let (super_tx, super_rx) = platform::channel().unwrap();
178178

179179
let data: Vec<u8> = (0..size).map(|i| (i % 251) as u8).collect();
180-
super_tx.send(&data[..], sender_fds, vec![]).unwrap();
180+
let thread = {
181+
let data = data.clone();
182+
thread::spawn(move || {
183+
super_tx.send(&data[..], sender_fds, vec![]).unwrap();
184+
})
185+
};
181186
let (received_data, received_channels, received_shared_memory_regions) =
182187
super_rx.recv().unwrap();
188+
thread.join().unwrap();
183189

184190
assert_eq!(received_data.len(), data.len());
185191
assert_eq!(&received_data[..], &data[..]);

0 commit comments

Comments
 (0)