@@ -115,7 +115,7 @@ public boolean handle(Request request, Response response, Callback callback)
115
115
endPoints .add (endPoint );
116
116
117
117
assertEquals (maxRequests , callbacks .size ());
118
- await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (1L ));
118
+ await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (1 ));
119
119
120
120
// Finish and verify the waiting requests.
121
121
List <Callback > copy = List .copyOf (callbacks );
@@ -130,7 +130,7 @@ public boolean handle(Request request, Response response, Callback callback)
130
130
}
131
131
132
132
// The suspended request should have been resumed.
133
- await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (0L ));
133
+ await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (0 ));
134
134
await ().atMost (5 , TimeUnit .SECONDS ).until (callbacks ::size , is (1 ));
135
135
136
136
// Finish the resumed request that is now waiting.
@@ -175,11 +175,11 @@ public boolean handle(Request request, Response response, Callback callback)
175
175
Host: localhost
176
176
177
177
""" );
178
- await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (1L ));
178
+ await ().atMost (5 , TimeUnit .SECONDS ).until (qosHandler ::getSuspendedRequestCount , is (1 ));
179
179
180
180
// Do not succeed the callback of the first request.
181
181
// Wait for the second request to time out.
182
- await ().atMost (2 * timeout , TimeUnit .MILLISECONDS ).until (qosHandler ::getSuspendedRequestCount , is (0L ));
182
+ await ().atMost (2 * timeout , TimeUnit .MILLISECONDS ).until (qosHandler ::getSuspendedRequestCount , is (0 ));
183
183
184
184
String text = endPoint1 .getResponse (false , 5 , TimeUnit .SECONDS );
185
185
HttpTester .Response response = HttpTester .parseResponse (text );
0 commit comments