Make sure the exception is thrown when it happens during test
This commit is contained in:
parent
8edee3272a
commit
86e95dd7ac
@ -104,7 +104,6 @@ public class SocketGatheringWriteTest extends AbstractSocketTest {
|
|||||||
// Ignore.
|
// Ignore.
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
assertEquals(Unpooled.wrappedBuffer(data), sh.received);
|
|
||||||
sh.channel.close().sync();
|
sh.channel.close().sync();
|
||||||
ch.channel.close().sync();
|
ch.channel.close().sync();
|
||||||
sc.close().sync();
|
sc.close().sync();
|
||||||
@ -122,6 +121,7 @@ public class SocketGatheringWriteTest extends AbstractSocketTest {
|
|||||||
throw ch.exception.get();
|
throw ch.exception.get();
|
||||||
}
|
}
|
||||||
assertEquals(0, ch.counter);
|
assertEquals(0, ch.counter);
|
||||||
|
assertEquals(Unpooled.wrappedBuffer(data), sh.received);
|
||||||
}
|
}
|
||||||
|
|
||||||
private static class TestHandler extends ChannelInboundHandlerAdapter {
|
private static class TestHandler extends ChannelInboundHandlerAdapter {
|
||||||
|
Loading…
Reference in New Issue
Block a user