Skip to content

Commit

Permalink
Fix seq_join print
Browse files Browse the repository at this point in the history
  • Loading branch information
akoshelev committed Nov 15, 2023
1 parent 55b662c commit 820ce78
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions src/seq_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -306,8 +306,12 @@ impl <'a, S, F, T> Stream for SequentialFutures<'a, S, F>
Poll::Pending
};

let _ = this.span.as_ref().map(|r| {
tracing::trace!("{r} seq_join polled. active before = {active_before}, active after = {}. Result = {r:?}", this.active.len());
let _ = this.span.as_ref().map(|step| {
let rp = match &r {
Poll::Ready(_) => "ready",
Poll::Pending => "pending"
};
tracing::trace!("{step} seq_join polled. active before = {active_before}, active after = {}. Result = {rp}", this.active.len());
});

r
Expand Down

0 comments on commit 820ce78

Please sign in to comment.