Skip to content

Commit

Permalink
Check if bug is inside seq_join
Browse files Browse the repository at this point in the history
  • Loading branch information
akoshelev committed Dec 12, 2023
1 parent a060692 commit ca99838
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions ipa-core/src/seq_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -188,6 +188,9 @@ where
let r = if let Some(item) = this.active.front_mut() {
if item.check_ready(cx) {
let v = this.active.pop_front().map(ActiveItem::take);
for f in this.active.iter_mut() {
f.check_ready(cx);
}
Poll::Ready(v)
} else {
for f in this.active.iter_mut().skip(1) {
Expand Down

0 comments on commit ca99838

Please sign in to comment.