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