Searched refs:ProtectedPromise (Results 1 – 2 of 2) sorted by relevance
37 final class ProtectedPromise extends DefaultChannelPromise { class44 ProtectedPromise(Channel channel, EventExecutor executor, int numUnprotectedPromises) { in ProtectedPromise() method in ProtectedPromise
148 final ProtectedPromise aggregatePromise = in flush()149 new ProtectedPromise(ctx.channel(), ctx.executor(), pendingUnprotectedWrites.size()); in flush()