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

Fixed a typo

Browse Source
This commit is contained in:
Trustin Lee 2011-03-09 00:20:47 +09:00
parent df656bf139
commit 77f79c3ea6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/handler/codec/replay/ReplayingDecoder.java
View File

@ -503,11 +503,11 @@ public abstract class ReplayingDecoder<T extends Enum<T>>
}
// A successful decode
unfoldAndfireMessageReceived(context, result, remoteAddress);
unfoldAndFireMessageReceived(context, result, remoteAddress);
}
}
private void unfoldAndfireMessageReceived(
private void unfoldAndFireMessageReceived(
ChannelHandlerContext context, Object result, SocketAddress remoteAddress) {
if (unfold) {
if (result instanceof Object[]) {
@ -546,7 +546,7 @@ public abstract class ReplayingDecoder<T extends Enum<T>>
// notify a user that the connection was closed explicitly.
Object partiallyDecoded = decodeLast(ctx, e.getChannel(), replayable, state);
if (partiallyDecoded != null) {
unfoldAndfireMessageReceived(ctx, partiallyDecoded, null);
unfoldAndFireMessageReceived(ctx, partiallyDecoded, null);
}
} catch (ReplayError replay) {
// Ignore