Fix some errors caused by the observer return fix
This commit is contained in:
parent
03a42f33a3
commit
9d546ef2a5
|
@ -1560,17 +1560,14 @@ mod example {
|
||||||
let second_consumer = Consumer;
|
let second_consumer = Consumer;
|
||||||
let arc_mut_second_consumer = Arc::new(Mutex::new(second_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),
|
None => assert!(false),
|
||||||
Some(err) => println!("You cannot subscribe twice: {}", err),
|
Some(err) => println!("You cannot subscribe twice: {}", err),
|
||||||
}
|
}
|
||||||
|
|
||||||
event.unsubscribe(arc_mut_consumer.clone());
|
event.unsubscribe(arc_mut_consumer.clone());
|
||||||
|
|
||||||
match event.subscribe(arc_mut_second_consumer.clone()) {
|
event.subscribe(arc_mut_second_consumer.clone()).unwrap();
|
||||||
None => assert!(true),
|
|
||||||
Some(_) => assert!(false),
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
|
|
Loading…
Reference in New Issue