Its called for every message so it should be the same, no?

Am 20.06.2013 um 09:03 schrieb Trustin Lee <notifications@github.com>:

> In transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest2.java:
> 
> > @@ -112,9 +111,8 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
> >          }
> >  
> >          @Override
> > -        public void messageReceived(ChannelHandlerContext ctx, MessageList<Object> msgs) throws Exception {
> > -            count.addAndGet(msgs.size());
> > -            msgs.recycle();
> > +        public void consume(ChannelHandlerContext ctx, Object msg) throws Exception {
> > +            count.incrementAndGet();
> It's obviously different from adding msgs.size() and adding 1 msg.size times.
> 
> —
> Reply to this email directly or view it on GitHub.