Compare commits
2 commits
79b13dc80f
...
5e38d4c280
Author | SHA1 | Date | |
---|---|---|---|
5e38d4c280 | |||
8d9838ce2b |
1 changed files with 6 additions and 5 deletions
|
@ -1,11 +1,9 @@
|
||||||
use std::time::Duration;
|
|
||||||
|
|
||||||
use crate::repo::messages::AdvanceNextPayload;
|
use crate::repo::messages::AdvanceNextPayload;
|
||||||
|
|
||||||
//
|
//
|
||||||
use super::*;
|
use super::*;
|
||||||
|
|
||||||
#[test_log::test(actix::test)]
|
#[actix::test]
|
||||||
async fn should_fetch_then_push_then_revalidate() -> TestResult {
|
async fn should_fetch_then_push_then_revalidate() -> TestResult {
|
||||||
//given
|
//given
|
||||||
let fs = given::a_filesystem();
|
let fs = given::a_filesystem();
|
||||||
|
@ -43,11 +41,14 @@ async fn should_fetch_then_push_then_revalidate() -> TestResult {
|
||||||
},
|
},
|
||||||
))
|
))
|
||||||
.await?;
|
.await?;
|
||||||
actix_rt::time::sleep(Duration::from_millis(1)).await;
|
|
||||||
System::current().stop();
|
System::current().stop();
|
||||||
|
|
||||||
//then
|
//then
|
||||||
tracing::debug!(?log, "");
|
tracing::debug!(?log, "");
|
||||||
log.require_message_containing("send: ValidateRepo")?;
|
log.read().map_err(|e| e.to_string()).map(|l| {
|
||||||
|
assert!(l
|
||||||
|
.iter()
|
||||||
|
.any(|message| message.contains("send: ValidateRepo")));
|
||||||
|
})?;
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue