I thought it make more sense here as it is the point where we flush. 

> Am 08.02.2014 um 01:31 schrieb Trustin Lee <notifications@github.com>:
> 
> In transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java:
> 
> > @@ -163,6 +164,19 @@ private void addCapacity() {
> >  
> >      void addFlush() {
> >          unflushed = tail;
> > +
> > +        int i = flushed;
> > +        final int mask = buffer.length - 1;
> > +        while (i != unflushed && buffer[i].msg != null) {
> > +            Entry entry = buffer[i];
> > +            if (!entry.promise.setUncancellable() && entry.promise.isCancelled()) {
> Can't you do this in current(..)?
> 
> —
> Reply to this email directly or view it on GitHub.