Class AsyncCompletion

src/main/java/com/aliyuncs/fc/core/AsyncCompletion.java:18–91

import java.util.concurrent.ExecutorService;

public class AsyncCompletion<Req extends HttpRequest, Res extends  HttpResponse> extends AbstractWatchableCallback<Req, Res>
        implements FutureCallback<Res> {
    private Req request;
    private ExecutorService executor;

    public AsyncCompletion(Req request, ExecutorService executor){
        this.request = request;
        this.executor = executor;
    }

    @Override
    public void completed(Res res) {
        this.onCompleted(request, res);
    }

    @Override
    public void failed(Exception ex) {
        ex.printStackTrace();
        final Object e;
        if (ex instanceof ClientException) {
            e = ex;
        } else if (ex instanceof ServerException) {
            e = ex;
        } else if(ex instanceof SocketTimeoutException) {
            e = new ClientException("SDK.ServerUnreachable",
                    "SocketTimeoutException has occurred on a socket read or accept." + ex.toString());
        } else if (ex instanceof InvalidKeyException) {
            e = new ClientException("SDK.InvalidAccessSecret",
                    "Speicified access secret is not valid.");
        } else if (ex instanceof IOException) {
            e = new ClientException("SDK.ServerUnreachable",
                    "Server unreachable: " + ex.toString());
        } else if (ex instanceof NoSuchAlgorithmException) {
            e = new ClientException("SDK.InvalidMD5Algorithm",
                    "MD5 hash is not supported by client side.");
        } else if (ex instanceof URISyntaxException) {
            throw new ClientException("SDK.InvalidURL", "url is not valid: " + ex.getMessage());
        } else {
            e = new ClientException("SDK.UnknownError", ex.getMessage(), ex.getCause());
        }
        this.onFailed(request, (Exception) e);
    }

    @Override
    public void cancelled() {

    }

    public void onCompleted(final Req req, final Res res) {
        Iterator it = callbacks.iterator();

        while(it.hasNext()) {
            final FcCallback<Req, Res> cb = (FcCallback)it.next();
            executor.submit(new Runnable() {
                public void run() {
                    cb.onCompleted(req, res);
                }
            });