()
| 243 | |
| 244 | #[test] |
| 245 | fn parallel_map_degree() { |
| 246 | let snap = make_snapshot(); |
| 247 | let config = ParallelConfig { |
| 248 | num_threads: 4, |
| 249 | min_partition_size: 10, |
| 250 | }; |
| 251 | |
| 252 | let degrees: Vec<usize> = parallel_map(&snap, &config, |node, s| s.out_degree_raw(node)); |
| 253 | |
| 254 | assert_eq!(degrees.len(), 100); |
| 255 | // Each node has out-degree 1 in a 100-node ring. |
| 256 | for &d in °rees { |
| 257 | assert_eq!(d, 1); |
| 258 | } |
| 259 | } |
| 260 | |
| 261 | #[test] |
| 262 | fn parallel_reduce_edge_count() { |
nothing calls this directly
no test coverage detected