andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Cleanup PendingWriteQueueTest

Browse Source 
Motivation:

PendingWriteQueueTest needs some cleanup.

Modifications:

- Cleanup code to remove deprecation warnings
- use static imports

Result:

No more warnings
This commit is contained in:
Norman Maurer 2015-10-07 10:35:12 +02:00
parent 99dfc9ea79
commit bd61b96efa
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java
View File

@ -196,7 +196,7 @@ public class PendingWriteQueueTest {
@Test @Test
public void testRemoveAndFailAllReentrance() { public void testRemoveAndFailAllReentrance() {
EmbeddedChannel channel = new EmbeddedChannel(new ChannelInboundHandlerAdapter()); EmbeddedChannel channel = new EmbeddedChannel();
final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext()); final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext());
ChannelPromise promise = channel.newPromise(); ChannelPromise promise = channel.newPromise();
@ -218,7 +218,7 @@ public class PendingWriteQueueTest {
@Test @Test
public void testRemoveAndWriteAllReentrance() { public void testRemoveAndWriteAllReentrance() {
EmbeddedChannel channel = new EmbeddedChannel(new ChannelInboundHandlerAdapter()); EmbeddedChannel channel = new EmbeddedChannel();
final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext()); final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext());
ChannelPromise promise = channel.newPromise(); ChannelPromise promise = channel.newPromise();