类io.netty.util.concurrent.GenericProgressiveFutureListener源码实例Demo

下面列出了怎么用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;
}
 
 类所在包
 类方法
 同包方法