Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
  • Loading branch information
jxs authored Jun 3, 2024
1 parent c7902f3 commit f23fee5
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions protocols/request-response/tests/error_reporting.rs
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ async fn report_outbound_failure_on_max_streams() {
.with_env_filter(EnvFilter::from_default_env())
.try_init();

// `swarm2` will be able to handle only 1 stream per time
// `swarm2` will be able to handle only 1 stream per time.
let swarm2_config = request_response::Config::default()
.with_request_timeout(Duration::from_millis(100))
.with_max_concurrent_streams(1);
Expand All @@ -183,11 +183,11 @@ async fn report_outbound_failure_on_max_streams() {
.behaviour_mut()
.send_request(&peer2_id, Action::FailOnMaxStreams);

// Keep the connection alive, otherwise swarm2 may receive `ConnectionClosed` instead
// Keep the connection alive, otherwise swarm2 may receive `ConnectionClosed` instead.
wait_no_events(&mut swarm1).await;
};

// Expects OutboundFailure::Io failure
// Expects OutboundFailure::Io failure.
let swarm2_task = async move {
let (peer, _inbound_req_id, action, _resp_channel) =
wait_request(&mut swarm2).await.unwrap();
Expand Down

0 comments on commit f23fee5

Please sign in to comment.