@@ -384,14 +384,14 @@ mod tests {
384
384
// When running the loop the first time, ev1 should be processed, but ev2 shouldn't
385
385
// because it was just added as part of processing ev1.
386
386
event_manager. run ( ) . unwrap ( ) ;
387
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , true ) ;
388
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) , false ) ;
387
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
388
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) ) ;
389
389
390
390
// Check that both ev1 and ev2 are processed.
391
391
dummy_subscriber. lock ( ) . unwrap ( ) . reset_state ( ) ;
392
392
event_manager. run ( ) . unwrap ( ) ;
393
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , true ) ;
394
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) , true ) ;
393
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
394
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) ) ;
395
395
}
396
396
397
397
#[ test]
@@ -416,13 +416,13 @@ mod tests {
416
416
dummy_subscriber. lock ( ) . unwrap ( ) . unregister_ev1 ( ) ;
417
417
418
418
event_manager. run ( ) . unwrap ( ) ;
419
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , true ) ;
419
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
420
420
421
421
dummy_subscriber. lock ( ) . unwrap ( ) . reset_state ( ) ;
422
422
423
423
// We expect no events to be available. Let's run with timeout so that run exists.
424
424
event_manager. run_with_timeout ( 100 ) . unwrap ( ) ;
425
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , false ) ;
425
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
426
426
}
427
427
428
428
#[ test]
@@ -435,8 +435,8 @@ mod tests {
435
435
// Modify ev1 so that it waits for EPOLL_IN.
436
436
dummy_subscriber. lock ( ) . unwrap ( ) . modify_ev1 ( ) ;
437
437
event_manager. run ( ) . unwrap ( ) ;
438
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , true ) ;
439
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) , false ) ;
438
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
439
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) ) ;
440
440
441
441
dummy_subscriber. lock ( ) . unwrap ( ) . reset_state ( ) ;
442
442
@@ -449,9 +449,9 @@ mod tests {
449
449
. unwrap ( ) ;
450
450
451
451
event_manager. run ( ) . unwrap ( ) ;
452
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , false ) ;
453
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) , false ) ;
454
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_in( ) , true ) ;
452
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
453
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev2_out( ) ) ;
454
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_in( ) ) ;
455
455
}
456
456
457
457
#[ test]
@@ -461,15 +461,15 @@ mod tests {
461
461
462
462
let subscriber_id = event_manager. add_subscriber ( dummy_subscriber. clone ( ) ) ;
463
463
event_manager. run ( ) . unwrap ( ) ;
464
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , true ) ;
464
+ assert ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
465
465
466
466
dummy_subscriber. lock ( ) . unwrap ( ) . reset_state ( ) ;
467
467
468
468
event_manager. remove_subscriber ( subscriber_id) . unwrap ( ) ;
469
469
470
470
// We expect no events to be available. Let's run with timeout so that run exits.
471
471
event_manager. run_with_timeout ( 100 ) . unwrap ( ) ;
472
- assert_eq ! ( dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) , false ) ;
472
+ assert ! ( ! dummy_subscriber. lock( ) . unwrap( ) . processed_ev1_out( ) ) ;
473
473
474
474
// Removing the subscriber twice should return an error.
475
475
assert_eq ! (
0 commit comments