Skip to content

Commit

Permalink
Issue #8170 - only fail stream if connection onIdleExpired returns true
Browse files Browse the repository at this point in the history
Co-authored-by: Simone Bordet <[email protected]>
  • Loading branch information
lachlan-roberts and sbordet authored Jun 17, 2022
1 parent e4b0db8 commit 1faa061
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,8 +57,11 @@ public boolean onTimeout(Throwable failure, Consumer<Runnable> consumer)
Connection connection = getConnection();
if (connection != null)
result = connection.onIdleExpired();
offerFailure(failure);
consumer.accept(() -> close(failure));
if (result)
{
offerFailure(failure);
consumer.accept(() -> close(failure));
}
return result;
}

Expand Down

0 comments on commit 1faa061

Please sign in to comment.