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

Let ChannelPromiseAggregator take a vararg of ChannelPromises and rename method

Browse Source
This commit is contained in:
Norman Maurer 2013-02-11 07:33:22 +01:00
parent df53d6d7c5
commit a22725d9fa
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
transport/src/main/java/io/netty/channel/ChannelPromiseAggregator.java
View File

@ -35,14 +35,23 @@ public final class ChannelPromiseAggregator implements ChannelFutureListener {
this.aggregatePromise = aggregatePromise;
}
public void addFuture(ChannelPromise promise) {
public ChannelPromiseAggregator add(ChannelPromise... promises) {
if (promises == null) {
throw new NullPointerException("promises");
}
synchronized (this) {
if (pendingPromises == null) {
pendingPromises = new HashSet<ChannelPromise>();
}
pendingPromises.add(promise);
for (ChannelPromise p: promises) {
if (p == null) {
continue;
}
pendingPromises.add(p);
p.addListener(this);
}
}
promise.addListener(this);
return this;
}
@Override