下面列出了怎么用io.netty.util.concurrent.GenericProgressiveFutureListener的API类实例代码及写法,或者点击链接到github查看源代码。
@SuppressWarnings("unchecked")
static <T extends ProgressiveFuture<?>> GenericProgressiveFutureListener<T> of(
RequestContext ctx, GenericProgressiveFutureListener listener) {
requireNonNull(ctx, "ctx");
requireNonNull(listener, "listener");
return new RequestContextAwareProgressiveFutureListener(ctx, listener);
}
@SuppressWarnings("unchecked")
static <T extends Future<?>> GenericFutureListener<T> of(
RequestContext ctx, GenericFutureListener listener) {
if (listener instanceof GenericProgressiveFutureListener) {
return (GenericFutureListener) RequestContextAwareProgressiveFutureListener.of(
ctx, (GenericProgressiveFutureListener) listener);
}
return new RequestContextAwareFutureListener(ctx, listener);
}
private RequestContextAwareProgressiveFutureListener(RequestContext ctx,
GenericProgressiveFutureListener listener) {
this.ctx = ctx;
this.listener = listener;
}