Skip to content

Commit

Permalink
fix: async protocol may stuck at the last round forever if messages n…
Browse files Browse the repository at this point in the history
…ot coming by order (#10)
  • Loading branch information
BigMurry authored Dec 21, 2022
1 parent 149512b commit 959126f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/async_runtime/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -178,7 +178,7 @@ where

async fn proceed_if_needed(&mut self) -> Result<(), Error<SM::Err, IErr, O::Error>> {
let mut state = self.state.take().ok_or(InternalError::MissingState)?;
if state.wants_to_proceed() {
while state.wants_to_proceed() {
let (result, s) = tokio::task::spawn_blocking(move || (state.proceed(), state))
.await
.map_err(Error::ProceedPanicked)?;
Expand Down

0 comments on commit 959126f

Please sign in to comment.