io.netty.util.concurrent.Promise.cause()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(176)

本文整理了Java中io.netty.util.concurrent.Promise.cause()方法的一些代码示例,展示了Promise.cause()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Promise.cause()方法的具体详情如下:
包路径:io.netty.util.concurrent.Promise
类名称:Promise
方法名:cause

Promise.cause介绍

暂无

代码示例

代码示例来源:origin: redisson/redisson

@Override
public Throwable cause() {
  return promise.cause();
}

代码示例来源:origin: redisson/redisson

@Override
public Throwable cause() {
  return promise.cause();
}

代码示例来源:origin: apache/hive

@Override
public Throwable getError() {
 return promise.cause();
}

代码示例来源:origin: line/armeria

@Override
public Throwable cause() {
  return delegate.cause();
}

代码示例来源:origin: netty/netty

/**
 * Try to cancel the {@link Promise} and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryCancel(Promise<?> p, InternalLogger logger) {
  if (!p.cancel(false) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to cancel promise because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to cancel promise because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: netty/netty

/**
 * Try to mark the {@link Promise} as success and log if {@code logger} is not {@code null} in case this fails.
 */
public static <V> void trySuccess(Promise<? super V> p, V result, InternalLogger logger) {
  if (!p.trySuccess(result) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as success because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to mark a promise as success because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: redisson/redisson

/**
 * Try to mark the {@link Promise} as success and log if {@code logger} is not {@code null} in case this fails.
 */
public static <V> void trySuccess(Promise<? super V> p, V result, InternalLogger logger) {
  if (!p.trySuccess(result) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as success because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to mark a promise as success because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: redisson/redisson

/**
 * Try to cancel the {@link Promise} and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryCancel(Promise<?> p, InternalLogger logger) {
  if (!p.cancel(false) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to cancel promise because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to cancel promise because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: netty/netty

/**
 * Try to mark the {@link Promise} as failure and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryFailure(Promise<?> p, Throwable cause, InternalLogger logger) {
  if (!p.tryFailure(cause) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as failure because it has succeeded already: {}", p, cause);
    } else {
      logger.warn(
          "Failed to mark a promise as failure because it has failed already: {}, unnotified cause: {}",
          p, ThrowableUtil.stackTraceToString(err), cause);
    }
  }
}

代码示例来源:origin: line/armeria

final Throwable firstCause = promise.cause();
if (firstCause instanceof TimeoutException) {

代码示例来源:origin: line/armeria

if (!(promise.cause() instanceof TimeoutException)) {

代码示例来源:origin: wildfly/wildfly

/**
 * Try to cancel the {@link Promise} and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryCancel(Promise<?> p, InternalLogger logger) {
  if (!p.cancel(false) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to cancel promise because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to cancel promise because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: redisson/redisson

/**
 * Try to mark the {@link Promise} as failure and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryFailure(Promise<?> p, Throwable cause, InternalLogger logger) {
  if (!p.tryFailure(cause) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as failure because it has succeeded already: {}", p, cause);
    } else {
      logger.warn(
          "Failed to mark a promise as failure because it has failed already: {}, unnotified cause: {}",
          p, ThrowableUtil.stackTraceToString(err), cause);
    }
  }
}

代码示例来源:origin: wildfly/wildfly

/**
 * Try to mark the {@link Promise} as success and log if {@code logger} is not {@code null} in case this fails.
 */
public static <V> void trySuccess(Promise<? super V> p, V result, InternalLogger logger) {
  if (!p.trySuccess(result) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as success because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to mark a promise as success because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: wildfly/wildfly

/**
 * Try to mark the {@link Promise} as failure and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryFailure(Promise<?> p, Throwable cause, InternalLogger logger) {
  if (!p.tryFailure(cause) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as failure because it has succeeded already: {}", p, cause);
    } else {
      logger.warn(
          "Failed to mark a promise as failure because it has failed already: {}, unnotified cause: {}",
          p, ThrowableUtil.stackTraceToString(err), cause);
    }
  }
}

代码示例来源:origin: apache/hive

private void fireStateChange(State newState, Listener<T> listener) {
 switch (newState) {
 case SENT:
  break;
 case QUEUED:
  listener.onJobQueued(this);
  break;
 case STARTED:
  listener.onJobStarted(this);
  break;
 case CANCELLED:
  listener.onJobCancelled(this);
  break;
 case FAILED:
  listener.onJobFailed(this, promise.cause());
  break;
 case SUCCEEDED:
  try {
   listener.onJobSucceeded(this, promise.get());
  } catch (Exception e) {
   // Shouldn't really happen.
   throw new IllegalStateException(e);
  }
  break;
 default:
  throw new IllegalStateException();
 }
}

代码示例来源:origin: io.netty/netty-common

/**
 * Try to cancel the {@link Promise} and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryCancel(Promise<?> p, InternalLogger logger) {
  if (!p.cancel(false) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to cancel promise because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to cancel promise because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: io.netty/netty-common

/**
 * Try to mark the {@link Promise} as success and log if {@code logger} is not {@code null} in case this fails.
 */
public static <V> void trySuccess(Promise<? super V> p, V result, InternalLogger logger) {
  if (!p.trySuccess(result) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as success because it has succeeded already: {}", p);
    } else {
      logger.warn(
          "Failed to mark a promise as success because it has failed already: {}, unnotified cause:",
          p, err);
    }
  }
}

代码示例来源:origin: io.netty/netty-common

/**
 * Try to mark the {@link Promise} as failure and log if {@code logger} is not {@code null} in case this fails.
 */
public static void tryFailure(Promise<?> p, Throwable cause, InternalLogger logger) {
  if (!p.tryFailure(cause) && logger != null) {
    Throwable err = p.cause();
    if (err == null) {
      logger.warn("Failed to mark a promise as failure because it has succeeded already: {}", p, cause);
    } else {
      logger.warn(
          "Failed to mark a promise as failure because it has failed already: {}, unnotified cause: {}",
          p, ThrowableUtil.stackTraceToString(err), cause);
    }
  }
}

代码示例来源:origin: com.cloudera.livy/livy-rsc

@Override
protected Throwable error() {
 return promise.cause();
}

相关文章