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

Promise.isSuccess介绍

暂无

代码示例

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

@Override
public boolean isSuccess() {
  return promise.isSuccess();
}

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

@Override
public boolean isSuccess() {
  return promise.isSuccess();
}

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

@Override
public boolean isSuccess() {
  return delegate.isSuccess();
}

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

@Override
 public void operationComplete(Promise<Rpc> p) {
  if (!p.isSuccess()) {
   pendingClients.remove(clientId);
  }
 }
});

代码示例来源：origin: com.simplyti.cloud/simple-server-clients

public boolean isSuccess() {
  return resultPromise.isSuccess();
}

代码示例来源：origin: com.github.hyukjinkwon/spark-client

@Override
 public void operationComplete(Promise<Rpc> p) {
  if (!p.isSuccess()) {
   pendingClients.remove(clientId);
  }
 }
});

代码示例来源：origin: org.spark-project.hive/spark-client

@Override
 public void operationComplete(Promise<Rpc> p) {
  if (!p.isSuccess()) {
   pendingClients.remove(clientId);
  }
 }
});

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

this.contextInfoPromise.cancel(true);
 if (shutdownContext && driverRpc.isSuccess()) {
  protocol.endSession();
 Utils.propagate(e);
} finally {
 if (driverRpc.isSuccess()) {
  try {
   driverRpc.get().close();

代码示例来源：origin: jurmous/etcd4j

/**
 * Handle the promise
 *
 * @param promise to handle
 */
protected void handlePromise(Promise<T> promise) {
 if (!promise.isSuccess()) {
  this.setException(promise.cause());
 } else {
  this.response = promise.getNow();
  if (handlers != null) {
   for (IsSimplePromiseResponseHandler<T> h : handlers) {
    h.onResponse(this);
   }
  }
 }
}

代码示例来源：origin: org.nanoframework/nano-ext-etcd

/**
 * Handle the promise
 *
 * @param promise to handle
 */
protected void handlePromise(Promise<T> promise) {
 if (!promise.isSuccess()) {
  this.setException(promise.cause());
 } else {
  this.response = promise.getNow();
  if (handlers != null) {
   for (IsSimplePromiseResponseHandler<T> h : handlers) {
    h.onResponse(this);
   }
  }
 }
}

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

assertTrue("Error during execution of TrafficShapping: " + promise.cause(), promise.isSuccess());

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

private <T> io.netty.util.concurrent.Future<T> deferredCall(final Object msg,
  final Class<T> retType) {
 if (driverRpc.isSuccess()) {
  try {
   return driverRpc.get().call(msg, retType);