Skip to content

Commit

Permalink
Fix spelling
Browse files Browse the repository at this point in the history
  • Loading branch information
aterentic-ethernal committed Oct 21, 2024
1 parent 80acc6f commit f4c37c6
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions core/src/network/rpc/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -123,11 +123,7 @@ impl Stream for MergedSubscriptions {
fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
// Randomly decide which stream to poll first
let poll_headers_first = rand::thread_rng().gen_bool(0.5);
if poll_headers_first {
self.poll_both(cx, true)
} else {
self.poll_both(cx, false)
}
self.poll_both(cx, poll_headers_first)
}
}

Expand Down Expand Up @@ -169,7 +165,7 @@ impl MergedSubscriptions {
error!("Error in Avail Headers stream: {:?}", e);
return Poll::Ready(Some(Err(e)));
},
// Do nothing here, fall into pooling the next stream
// Do nothing here, fall into polling the next stream
Poll::Pending => {},
}

Expand Down

0 comments on commit f4c37c6

Please sign in to comment.