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

Use MessageList.first() and last() wherever possible

Browse Source 
- Related issue: #1530
This commit is contained in:
Trustin Lee 2013-07-05 14:11:09 +09:00
parent b7e6a86c1e
commit eb8df35f21
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java
View File

@ -338,11 +338,11 @@ public class DefaultChannelPipelineTest {
public void run() {
ChannelPipeline p = self.pipeline();
handler1.inboundBuffer.add(8);
assertEquals(8, handler1.inboundBuffer.get(0));
assertEquals(8, handler1.inboundBuffer.first());
assertTrue(handler2.inboundBuffer.isEmpty());
p.remove(handler1);
assertEquals(1, handler2.inboundBuffer.size());
assertEquals(8, handler2.inboundBuffer.get(0));
assertEquals(8, handler2.inboundBuffer.first());
}
}).sync();
}
@ -359,11 +359,11 @@ public class DefaultChannelPipelineTest {
public void run() {
ChannelPipeline p = self.pipeline();
handler2.outboundBuffer.add(8);
assertEquals(8, handler2.outboundBuffer.get(0));
assertEquals(8, handler2.outboundBuffer.first());
assertTrue(handler1.outboundBuffer.isEmpty());
p.remove(handler2);
assertEquals(1, handler1.outboundBuffer.size());
assertEquals(8, handler1.outboundBuffer.get(0));
assertEquals(8, handler1.outboundBuffer.first());
}
}).sync();
}
@ -380,10 +380,10 @@ public class DefaultChannelPipelineTest {
public void run() {
ChannelPipeline p = self.pipeline();
handler1.outboundBuffer.add(8);
assertEquals(8, handler1.outboundBuffer.get(0));
assertEquals(8, handler1.outboundBuffer.first());
assertTrue(handler2.outboundBuffer.isEmpty());
p.replace(handler1, "handler2", handler2);
assertEquals(8, handler2.outboundBuffer.get(0));
assertEquals(8, handler2.outboundBuffer.first());
}
}).sync();
}
@ -402,14 +402,14 @@ public class DefaultChannelPipelineTest {
handler1.inboundBuffer.add(8);
handler1.outboundBuffer.add(8);
assertEquals(8, handler1.inboundBuffer.get(0));
assertEquals(8, handler1.outboundBuffer.get(0));
assertEquals(8, handler1.inboundBuffer.first());
assertEquals(8, handler1.outboundBuffer.first());
assertTrue(handler2.inboundBuffer.isEmpty());
assertTrue(handler2.outboundBuffer.isEmpty());
p.replace(handler1, "handler2", handler2);
assertEquals(8, handler2.outboundBuffer.get(0));
assertEquals(8, handler2.inboundBuffer.get(0));
assertEquals(8, handler2.outboundBuffer.first());
assertEquals(8, handler2.inboundBuffer.first());
}
}).sync();
}
@ -429,15 +429,15 @@ public class DefaultChannelPipelineTest {
handler2.inboundBuffer.add(8);
handler2.outboundBuffer.add(8);
assertEquals(8, handler2.inboundBuffer.get(0));
assertEquals(8, handler2.outboundBuffer.get(0));
assertEquals(8, handler2.inboundBuffer.first());
assertEquals(8, handler2.outboundBuffer.first());
assertEquals(0, handler1.outboundBuffer.size());
assertEquals(0, handler3.inboundBuffer.size());
p.remove(handler2);
assertEquals(8, handler3.inboundBuffer.get(0));
assertEquals(8, handler1.outboundBuffer.get(0));
assertEquals(8, handler3.inboundBuffer.first());
assertEquals(8, handler1.outboundBuffer.first());
}
}).sync();
}