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

Typo

Browse Source
This commit is contained in:
Trustin Lee 2013-04-21 07:45:37 +09:00
parent 475039532c
commit 5846693577
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest3.java
View File

@ -50,7 +50,7 @@ public class LocalTransportThreadModelTest3 {
ACTIVE, ACTIVE,
UNREGISTERED, UNREGISTERED,
REGISTERED, REGISTERED,
INBOUND_BuFFER_UPDATED, INBOUND_BUFFER_UPDATED,
FLUSH, FLUSH,
READ READ
} }
@ -176,7 +176,7 @@ public class LocalTransportThreadModelTest3 {
case EXCEPTION_CAUGHT: case EXCEPTION_CAUGHT:
ch.pipeline().fireExceptionCaught(cause); ch.pipeline().fireExceptionCaught(cause);
break; break;
case INBOUND_BuFFER_UPDATED: case INBOUND_BUFFER_UPDATED:
ch.pipeline().fireInboundBufferUpdated(); ch.pipeline().fireInboundBufferUpdated();
break; break;
case READ_SUSPEND: case READ_SUSPEND:
@ -227,7 +227,7 @@ public class LocalTransportThreadModelTest3 {
EventType[] events; EventType[] events;
if (inbound) { if (inbound) {
events = new EventType[] { events = new EventType[] {
EventType.USER_EVENT, EventType.INBOUND_BuFFER_UPDATED, EventType.READ_SUSPEND, EventType.EXCEPTION_CAUGHT}; EventType.USER_EVENT, EventType.INBOUND_BUFFER_UPDATED, EventType.READ_SUSPEND, EventType.EXCEPTION_CAUGHT};
} else { } else {
events = new EventType[] { events = new EventType[] {
EventType.READ, EventType.FLUSH, EventType.EXCEPTION_CAUGHT }; EventType.READ, EventType.FLUSH, EventType.EXCEPTION_CAUGHT };
@ -305,7 +305,7 @@ public class LocalTransportThreadModelTest3 {
@Override @Override
public void inboundBufferUpdated(ChannelHandlerContext ctx) throws Exception { public void inboundBufferUpdated(ChannelHandlerContext ctx) throws Exception {
if (inbound) { if (inbound) {
events.add(EventType.INBOUND_BuFFER_UPDATED); events.add(EventType.INBOUND_BUFFER_UPDATED);
} }
} }