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

Fix compilation errors

Browse Source
This commit is contained in:
Trustin Lee 2012-05-23 11:47:37 -07:00
parent debaa6a72a
commit a2d57144b4
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
transport/src/main/java/io/netty/channel/group/ChannelGroup.java
View File

@ -15,7 +15,6 @@
*/
package io.netty.channel.group;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.buffer.ChannelBuffer;
import io.netty.buffer.ChannelBuffers;
import io.netty.channel.Channel;

4
transport/src/main/java/io/netty/channel/group/DefaultChannelGroup.java
View File

@ -116,7 +116,7 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
boolean added = map.putIfAbsent(channel.id(), channel) == null;
if (added) {
channel.addClosureListener(remover);
channel.closeFuture().addListener(remover);
}
return added;
}
@ -142,7 +142,7 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
return false;
}
c.removeClosureListener(remover);
c.closeFuture().removeListener(remover);
return true;
}