equal
deleted
inserted
replaced
231 assertTrue(b == 99); |
231 assertTrue(b == 99); |
232 }); |
232 }); |
233 } |
233 } |
234 |
234 |
235 /** |
235 /** |
236 * Test writing after a timed read. The timed read changes the underlying |
236 * Test writing after a timed read. |
237 * socket to non-blocking. |
|
238 */ |
237 */ |
239 public void testTimedWrite1() throws IOException { |
238 public void testTimedWrite1() throws IOException { |
240 withConnection((s1, s2) -> { |
239 withConnection((s1, s2) -> { |
241 s1.getOutputStream().write(99); |
240 s1.getOutputStream().write(99); |
242 s2.setSoTimeout(3000); |
241 s2.setSoTimeout(3000); |
253 } |
252 } |
254 }); |
253 }); |
255 } |
254 } |
256 |
255 |
257 /** |
256 /** |
258 * Test async close of writer (after a timed read). The timed read changes |
257 * Test async close of writer (after a timed read). |
259 * the underlying socket to non-blocking. |
|
260 */ |
258 */ |
261 public void testTimedWrite2() throws IOException { |
259 public void testTimedWrite2() throws IOException { |
262 withConnection((s1, s2) -> { |
260 withConnection((s1, s2) -> { |
263 s1.getOutputStream().write(99); |
261 s1.getOutputStream().write(99); |
264 s2.setSoTimeout(3000); |
262 s2.setSoTimeout(3000); |