diff --git a/transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java b/transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java index 6ee160b2f8..e807b563e3 100644 --- a/transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java +++ b/transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java @@ -166,7 +166,7 @@ public interface ChannelGroupFuture extends Iterable { * {@linkplain #isDone() done}. If this future is already * completed, the specified listener is notified immediately. */ - void addListener(ChannelGroupFutureListener listener); + ChannelGroupFuture addListener(ChannelGroupFutureListener listener); /** * Removes the specified listener from this future. @@ -175,7 +175,7 @@ public interface ChannelGroupFuture extends Iterable { * future is already completed, this method has no effect * and returns silently. */ - void removeListener(ChannelGroupFutureListener listener); + ChannelGroupFuture removeListener(ChannelGroupFutureListener listener); /** * Waits for this future to be completed. diff --git a/transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java b/transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java index 6a151d2cdb..4664658201 100644 --- a/transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java +++ b/transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java @@ -161,7 +161,7 @@ public class DefaultChannelGroupFuture implements ChannelGroupFuture { } @Override - public void addListener(ChannelGroupFutureListener listener) { + public ChannelGroupFuture addListener(ChannelGroupFutureListener listener) { if (listener == null) { throw new NullPointerException("listener"); } @@ -185,10 +185,11 @@ public class DefaultChannelGroupFuture implements ChannelGroupFuture { if (notifyNow) { notifyListener(listener); } + return this; } @Override - public void removeListener(ChannelGroupFutureListener listener) { + public ChannelGroupFuture removeListener(ChannelGroupFutureListener listener) { if (listener == null) { throw new NullPointerException("listener"); } @@ -206,6 +207,7 @@ public class DefaultChannelGroupFuture implements ChannelGroupFuture { } } } + return this; } @Override