Fixed a typo

This commit is contained in:
Trustin Lee 2011-03-09 00:20:47 +09:00
parent ec6b34a307
commit 6707aa751c

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