@@ -319,7 +319,7 @@ mod tests {
319
319
320
320
#[ test]
321
321
fn with_parallel_unsafe ( ) -> anyhow:: Result < ( ) > {
322
- let geometry = create_geometry ( 5 ) ;
322
+ let geometry = create_geometry ( 2 ) ;
323
323
324
324
let mut rng = rand:: thread_rng ( ) ;
325
325
@@ -344,16 +344,13 @@ mod tests {
344
344
let gain = Group :: new ( |dev| {
345
345
let dev_idx = dev. idx ( ) ;
346
346
move |tr| match ( dev_idx, tr. idx ( ) ) {
347
- ( 0 , 0 ..=99 ) => Some ( "null" ) ,
348
347
( 0 , 100 ..=199 ) => Some ( "test" ) ,
349
348
( 1 , 200 ..) => Some ( "test2" ) ,
350
- ( 3 , _) => Some ( "test" ) ,
351
349
_ => None ,
352
350
}
353
351
} )
354
- . set ( "null" , Null { } . into_boxed ( ) ) ?
355
- . set ( "test" , g1. into_boxed ( ) ) ?
356
- . set ( "test2" , g2. into_boxed ( ) ) ?;
352
+ . set ( "test" , g1) ?
353
+ . set ( "test2" , g2) ?;
357
354
358
355
let mut g = gain. init_full ( & geometry, None , true ) ?;
359
356
let drives = geometry
@@ -366,7 +363,7 @@ mod tests {
366
363
)
367
364
} )
368
365
. collect :: < HashMap < _ , _ > > ( ) ;
369
- assert_eq ! ( 5 , drives. len( ) ) ;
366
+ assert_eq ! ( 2 , drives. len( ) ) ;
370
367
drives[ & 0 ] . iter ( ) . enumerate ( ) . for_each ( |( i, & d) | match i {
371
368
i if i <= 99 => {
372
369
assert_eq ! ( Drive :: NULL , d) ;
@@ -386,15 +383,6 @@ mod tests {
386
383
assert_eq ! ( d2, d) ;
387
384
}
388
385
} ) ;
389
- drives[ & 2 ] . iter ( ) . for_each ( |& d| {
390
- assert_eq ! ( Drive :: NULL , d) ;
391
- } ) ;
392
- drives[ & 3 ] . iter ( ) . for_each ( |& d| {
393
- assert_eq ! ( d1, d) ;
394
- } ) ;
395
- drives[ & 4 ] . iter ( ) . for_each ( |& d| {
396
- assert_eq ! ( Drive :: NULL , d) ;
397
- } ) ;
398
386
399
387
Ok ( ( ) )
400
388
}
0 commit comments