fix(chainsync): Stop the consumer machine when intersect is not found (#14)
This commit is contained in:
parent
5df211599c
commit
f457c44d24
1 changed files with 2 additions and 2 deletions
|
|
@ -131,7 +131,7 @@ where
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
tip: Some(tip),
|
tip: Some(tip),
|
||||||
cursor: None,
|
cursor: None,
|
||||||
state: State::Idle,
|
state: State::Done,
|
||||||
..self
|
..self
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
@ -145,7 +145,7 @@ where
|
||||||
trace!("content: {:?}", content);
|
trace!("content: {:?}", content);
|
||||||
}
|
}
|
||||||
|
|
||||||
debug!("reporint block to observer");
|
debug!("reporting block to observer");
|
||||||
self.observer.on_block(&self.cursor, &content)?;
|
self.observer.on_block(&self.cursor, &content)?;
|
||||||
|
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue