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

AsyncResponse.complete介绍

暂无

代码示例

代码示例来源：origin: apache/servicecomb-java-chassis

private void next(AsyncResponse asyncResponse) {
  if (handlerIndex >= faultInjectList.size()) {
   asyncResponse.complete(Response.succResp("success"));
   return;
  }

  int runIndex = handlerIndex;
  handlerIndex++;
  faultInjectList.get(runIndex).injectFault(invocation, param, response -> {
   if (response.isFailed()) {
    asyncResponse.complete(response);
   } else {
    FaultExecutor.this.next(asyncResponse);
   }
  });
 }
}

代码示例来源：origin: apache/servicecomb-java-chassis

@Override
public void onExecutionSuccess(ExecutionContext<Invocation> context, Response response,
  ExecutionInfo info) {
 if (info.getNumberOfPastServersAttempted() > 0 || info.getNumberOfPastAttemptsOnServer() > 0) {
  LOGGER.error("Invoke server success. Operation {}; server {}",
    context.getRequest().getInvocationQualifiedName(),
    context.getRequest().getEndpoint());
 }
 if (orginExecutor != null) {
  orginExecutor.execute(() -> {
   asyncResp.complete(response);
  });
 } else {
  asyncResp.complete(response);
 }
}

代码示例来源：origin: apache/servicecomb-java-chassis

protected void complete(Response response) {
 DefaultHttpSocketMetric httpSocketMetric = (DefaultHttpSocketMetric) ((ConnectionBase) clientRequest.connection())
   .metric();
 invocation.getInvocationStageTrace().finishGetConnection(httpSocketMetric.getRequestBeginTime());
 invocation.getInvocationStageTrace().finishWriteToBuffer(httpSocketMetric.getRequestEndTime());
 invocation.getInvocationStageTrace().finishClientFiltersResponse();
 asyncResp.complete(response);
}

代码示例来源：origin: apache/servicecomb-java-chassis

@Override
 public void handle(Invocation invocation, AsyncResponse asyncResp) throws Exception {

  // prepare the key and lookup for request count.
  String key = invocation.getTransport().getName() + invocation.getMicroserviceQualifiedName();
  AtomicLong reqCount = FaultInjectionUtil.getOperMetTotalReq(key);
  // increment the request count here after checking the delay/abort condition.
  long reqCountCurrent = reqCount.getAndIncrement();

  FaultParam param = new FaultParam(reqCountCurrent);
  Context currentContext = Vertx.currentContext();
  if (currentContext != null && currentContext.isEventLoopContext()) {
   param.setVertx(currentContext.owner());
  }

  FaultExecutor executor = new FaultExecutor(faultInjectionFeatureList, invocation, param);
  executor.execute(response -> {
   try {
    if (response.isFailed()) {
     asyncResp.complete(response);
    } else {
     invocation.next(asyncResp);
    }
   } catch (Exception e) {
    asyncResp.consumerFail(e);
   }
  });
 }
}

代码示例来源：origin: apache/servicecomb-java-chassis

ar.result());
 invocation.getInvocationStageTrace().finishClientFiltersResponse();
 asyncResp.complete(response);
} catch (Throwable e) {
 invocation.getInvocationStageTrace().finishClientFiltersResponse();

代码示例来源：origin: org.apache.servicecomb/handler-fault-injection

private void next(AsyncResponse asyncResponse) {
  if (handlerIndex >= faultInjectList.size()) {
   asyncResponse.complete(Response.succResp("success"));
   return;
  }

  int runIndex = handlerIndex;
  handlerIndex++;
  faultInjectList.get(runIndex).injectFault(invocation, param, response -> {
   if (response.isFailed()) {
    asyncResponse.complete(response);
   } else {
    FaultExecutor.this.next(asyncResponse);
   }
  });
 }
}

代码示例来源：origin: org.apache.servicecomb/handler-loadbalance

@Override
public void onExecutionSuccess(ExecutionContext<Invocation> context, Response response,
  ExecutionInfo info) {
 if (info.getNumberOfPastServersAttempted() > 0 || info.getNumberOfPastAttemptsOnServer() > 0) {
  LOGGER.error("Invoke server success. Operation {}; server {}",
    context.getRequest().getInvocationQualifiedName(),
    context.getRequest().getEndpoint());
 }
 if (orginExecutor != null) {
  orginExecutor.execute(() -> {
   asyncResp.complete(response);
  });
 } else {
  asyncResp.complete(response);
 }
}

代码示例来源：origin: org.apache.servicecomb/transport-rest-client

protected void complete(Response response) {
 DefaultHttpSocketMetric httpSocketMetric = (DefaultHttpSocketMetric) ((ConnectionBase) clientRequest.connection())
   .metric();
 invocation.getInvocationStageTrace().finishGetConnection(httpSocketMetric.getRequestBeginTime());
 invocation.getInvocationStageTrace().finishWriteToBuffer(httpSocketMetric.getRequestEndTime());
 invocation.getInvocationStageTrace().finishClientFiltersResponse();
 asyncResp.complete(response);
}

代码示例来源：origin: org.apache.servicecomb/handler-fault-injection

@Override
 public void handle(Invocation invocation, AsyncResponse asyncResp) throws Exception {

  // prepare the key and lookup for request count.
  String key = invocation.getTransport().getName() + invocation.getMicroserviceQualifiedName();
  AtomicLong reqCount = FaultInjectionUtil.getOperMetTotalReq(key);
  // increment the request count here after checking the delay/abort condition.
  long reqCountCurrent = reqCount.getAndIncrement();

  FaultParam param = new FaultParam(reqCountCurrent);
  Context currentContext = Vertx.currentContext();
  if (currentContext != null && currentContext.isEventLoopContext()) {
   param.setVertx(currentContext.owner());
  }

  FaultExecutor executor = new FaultExecutor(faultInjectionFeatureList, invocation, param);
  executor.execute(response -> {
   try {
    if (response.isFailed()) {
     asyncResp.complete(response);
    } else {
     invocation.next(asyncResp);
    }
   } catch (Exception e) {
    asyncResp.consumerFail(e);
   }
  });
 }
}

代码示例来源：origin: org.apache.servicecomb/transport-highway

ar.result());
 invocation.getInvocationStageTrace().finishClientFiltersResponse();
 asyncResp.complete(response);
} catch (Throwable e) {
 invocation.getInvocationStageTrace().finishClientFiltersResponse();