javax.ws.rs.client.AsyncInvoker.delete()方法的使用及代码示例

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

AsyncInvoker.delete介绍

[英]Invoke HTTP DELETE method for the current request asynchronously.

Note that calling the java.util.concurrent.Future#get() method on the returned Future instance may throw an java.util.concurrent.ExecutionExceptionthat wraps a javax.ws.rs.ProcessingException thrown in case of an invocation processing failure. In case a processing of a properly received response fails, the wrapped processing exception will be of ResponseProcessingException type and will contain the Responseinstance whose processing has failed.
[中]异步调用当前请求的HTTP DELETE方法。
请注意，调用java。util。同时发生的返回的Future实例上的Future#get（）方法可能会抛出java错误。util。同时发生的包装javax的executionexception。ws。调用处理失败时引发rs.ProcessingException。如果正确接收的响应处理失败，包装的处理异常将为ResponseProcessingException类型，并将包含处理失败的Responseinstance。

代码示例

代码示例来源：origin: aol/micro-server

public CompletableFuture delete(final String queryResourceUrl) {
CompletableFuture result = new CompletableFuture<>();
final WebTarget webResource = client.target(queryResourceUrl);
webResource
.request(accept)
.accept(accept)
.async()
.delete(new InvocationCallback() {
@Override
public void completed(String complete) {
buildResponse(result,complete);
}
@Override
public void failed(Throwable ex) {
result.completeExceptionally(ex);
}
});
return result;
}
}

代码示例来源：origin: net.oneandone.reactive/reactive-http

@Override
public Future delete(InvocationCallback callback) {
return asyncInvoker.delete(callback);
}

代码示例来源：origin: grro/stability

@Override
public Future delete(InvocationCallback callback) {
return asyncInvoker.delete(callback);
}

代码示例来源：origin: com.yahoo.pulsar/pulsar-client-admin

public CompletableFuture asyncDeleteRequest(final WebTarget target) {
final CompletableFuture future = new CompletableFuture<>();
try {
request(target).async().delete(new InvocationCallback() {
@Override
public void completed(ErrorData response) {
future.complete(null);
}
@Override
public void failed(Throwable throwable) {
log.warn("[{}] Failed to perform http delete request: {}", target.getUri(), throwable.getMessage());
future.completeExceptionally(getApiException(throwable.getCause()));
}
});
} catch (PulsarAdminException cae) {
future.completeExceptionally(cae);
}
return future;
}

代码示例来源：origin: net.oneandone.reactive/reactive-http

@Override
public CompletableFuture delete(Class responseType) {
CompletableFutureObjectCallbackAdapter adapter = new CompletableFutureObjectCallbackAdapter<>(responseType);
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: grro/stability

@Override
public CompletableFuture delete(Class responseType) {
CompletableFutureObjectCallbackAdapter adapter = new CompletableFutureObjectCallbackAdapter<>(responseType);
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: net.oneandone.reactive/reactive-http

@Override
public CompletableFuture delete() {
CompletableFutureCallbackAdapter adapter = new CompletableFutureCallbackAdapter();
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: grro/stability

@Override
public CompletableFuture delete() {
CompletableFutureCallbackAdapter adapter = new CompletableFutureCallbackAdapter();
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: net.oneandone.reactive/reactive-http

@Override
public CompletableFuture delete(GenericType responseType) {
CompletableFutureGenericObjectCallbackAdapter adapter = new CompletableFutureGenericObjectCallbackAdapter<>(responseType);
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: com.aol.microservices/micro-client

public CompletableFuture delete(final String queryResourceUrl) {
CompletableFuture result = new CompletableFuture<>();
final WebTarget webResource = client.target(queryResourceUrl);
webResource
.request(accept)
.accept(accept)
.async()
.delete(new InvocationCallback() {
@Override
public void completed(String complete) {
buildResponse(result,complete);
}
@Override
public void failed(Throwable ex) {
result.completeExceptionally(ex);
}
});
return result;
}
}

代码示例来源：origin: com.oath.microservices/micro-client

public CompletableFuture delete(final String queryResourceUrl) {
CompletableFuture result = new CompletableFuture<>();
final WebTarget webResource = client.target(queryResourceUrl);
webResource
.request(accept)
.accept(accept)
.async()
.delete(new InvocationCallback() {
@Override
public void completed(String complete) {
buildResponse(result,complete);
}
@Override
public void failed(Throwable ex) {
result.completeExceptionally(ex);
}
});
return result;
}
}

代码示例来源：origin: org.apache.pulsar/pulsar-client-admin-original

public CompletableFuture asyncDeleteRequest(final WebTarget target) {
final CompletableFuture future = new CompletableFuture<>();
try {
request(target).async().delete(new InvocationCallback() {
@Override
public void completed(ErrorData response) {
future.complete(null);
}
@Override
public void failed(Throwable throwable) {
log.warn("[{}] Failed to perform http delete request: {}", target.getUri(), throwable.getMessage());
future.completeExceptionally(getApiException(throwable.getCause()));
}
});
} catch (PulsarAdminException cae) {
future.completeExceptionally(cae);
}
return future;
}

代码示例来源：origin: grro/stability

@Override
public CompletableFuture delete(GenericType responseType) {
CompletableFutureGenericObjectCallbackAdapter adapter = new CompletableFutureGenericObjectCallbackAdapter<>(responseType);
asyncInvoker.delete(adapter);
return adapter.getCompletableFuture();
}

代码示例来源：origin: oracle/oci-java-sdk

/**
* Execute a delete on a resource asynchronously and get the response.
*
* @param ib
* An invocation builder to execute requests with.
* @param request
* The original client request object given to the service
* client.
* @param onSuccess
* The callback to invoke on success.
* @param onError
* The callback to invoke on failure.
* @return A Future that can be used to get the Response if no Consumer was
* provided. Note, callers should be careful not to read the entity
* from both the future and the consumer, as the entity stream may
* not be able to support being consumed twice.
*/
public Future delete(
@NonNull WrappedInvocationBuilder ib,
@NonNull T request,
@Nullable Consumer onSuccess,
@Nullable Consumer onError) {
InvocationInformation info = preprocessRequest(ib, request);
if (OnSuccess== null && OnError== null) {
return ib.async().delete();
} else {
return ib.async().delete(new Callback(baseTarget, info, onSuccess, onError));
}
}

代码示例来源：origin: io.github.ma1uta.matrix/client-sdk

/**
* Send the DELETE request.
*
* @param apiClass The target API.
* @param apiMethod The concrete API method.
* @param params The request params (query, path and header).
* @return the {@link CompletableFuture} instance to make async request.
*/
public CompletableFuture delete(Class apiClass, String apiMethod, RequestParams params) {
return invoke(() -> buildRequest(apiClass, apiMethod, params, MediaType.APPLICATION_JSON).async().delete(),
extractor(EmptyResponse.class));
}