parent
e744926817
commit
4302c016d2
@ -161,13 +161,13 @@ public interface ChannelGroup extends Set<Channel>, Comparable<ChannelGroup> {
|
||||
/**
|
||||
* Shortcut for calling {@link #write(Object)} and {@link #flush()}.
|
||||
*/
|
||||
ChannelGroupFuture flushAndWrite(Object message);
|
||||
ChannelGroupFuture writeAndFlush(Object message);
|
||||
|
||||
/**
|
||||
* Shortcut for calling {@link #write(Object)} and {@link #flush()} and only act on
|
||||
* {@link Channel}s that match the {@link ChannelMatcher}.
|
||||
*/
|
||||
ChannelGroupFuture flushAndWrite(Object message, ChannelMatcher matcher);
|
||||
ChannelGroupFuture writeAndFlush(Object message, ChannelMatcher matcher);
|
||||
|
||||
/**
|
||||
* Disconnects all {@link Channel}s in this group from their remote peers.
|
||||
|
@ -232,8 +232,8 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
|
||||
}
|
||||
|
||||
@Override
|
||||
public ChannelGroupFuture flushAndWrite(Object message) {
|
||||
return flushAndWrite(message, ChannelMatchers.all());
|
||||
public ChannelGroupFuture writeAndFlush(Object message) {
|
||||
return writeAndFlush(message, ChannelMatchers.all());
|
||||
}
|
||||
|
||||
@Override
|
||||
@ -293,7 +293,7 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
|
||||
}
|
||||
|
||||
@Override
|
||||
public ChannelGroupFuture flushAndWrite(Object message, ChannelMatcher matcher) {
|
||||
public ChannelGroupFuture writeAndFlush(Object message, ChannelMatcher matcher) {
|
||||
if (message == null) {
|
||||
throw new NullPointerException("message");
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user