Searched refs:aggregatePromise (Results 1 – 1 of 1) sorted by relevance
148 final ProtectedPromise aggregatePromise = in flush() local164 aggregatePromise.addUnprotectedPromise(pendingUnprotectedWrites.remove()); in flush()172 ctx.writeAndFlush(b, aggregatePromise.newPromise()); in flush()179 Future<?> possiblyIgnoredError = aggregatePromise.doneAllocatingPromises(); in flush()