Fix some errors caused by the observer return fix

This commit is contained in:
kozabrada123 2023-05-29 17:11:08 +02:00
parent 521c4cf5e2
commit 90ebc823ba
1 changed files with 2 additions and 5 deletions

View File

@ -1560,17 +1560,14 @@ mod example {
let second_consumer = Consumer;
let arc_mut_second_consumer = Arc::new(Mutex::new(second_consumer));
match event.subscribe(arc_mut_second_consumer.clone()) {
match event.subscribe(arc_mut_second_consumer.clone()).err() {
None => assert!(false),
Some(err) => println!("You cannot subscribe twice: {}", err),
}
event.unsubscribe(arc_mut_consumer.clone());
match event.subscribe(arc_mut_second_consumer.clone()) {
None => assert!(true),
Some(_) => assert!(false),
}
event.subscribe(arc_mut_second_consumer.clone()).unwrap();
}
#[tokio::test]