Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * COMSAT
   * Copyright (c) 2013-2014, Parallel Universe Software Co. All rights reserved.
   *
   * This program and the accompanying materials are dual-licensed under
   * either the terms of the Eclipse Public License v1.0 as published by
   * the Eclipse Foundation
   *
   *   or (per the licensee's choosing)
  *
  * under the terms of the GNU Lesser General Public License version 3.0
  * as published by the Free Software Foundation.
  */
 package co.paralleluniverse.fibers.ws.rs.client;
 
 import  co.paralleluniverse.fibers.SuspendExecution;
 import  co.paralleluniverse.fibers.Suspendable;
 
 class FiberBuilder implements Invocation.Builder {
     private static final String GET = "GET";
     private static final String PUT = "PUT";
     private static final String POST = "POST";
     private static final String DELETE = "DELETE";
     private static final String HEAD = "HEAD";
     private static final String OPTIONS = "OPTIONS";
     private static final String TRACE = "TRACE";
 
     public FiberBuilder(Builder builder) {
         this. = builder;
     }
 
     // Wrap FiberInvocation
     @Override
     public Invocation build(String method) {
         return new FiberInvocation(.build(method));
     }
 
     @Override
     public Invocation build(String methodEntity<?> entity) {
         return new FiberInvocation(.build(methodentity));
     }
 
     @Override
     public Invocation buildGet() {
         return new FiberInvocation(.buildGet());
     }
 
     @Override
     public Invocation buildDelete() {
         return new FiberInvocation(.buildDelete());
     }
 
     @Override
     public Invocation buildPost(Entity<?> entity) {
         return new FiberInvocation(.buildPost(entity));
     }
 
     @Override
     public Invocation buildPut(Entity<?> entity) {
         return new FiberInvocation(.buildPut(entity));
     }
 
     // Return this instead of builder
     @Override
     public Builder accept(String... mediaTypes) {
         .accept(mediaTypes);
         return this;
     }
 
     @Override
     public Builder accept(MediaType... mediaTypes) {
         .accept(mediaTypes);
         return this;
     }
 
     @Override
     public Builder acceptLanguage(Locale... locales) {
         .acceptLanguage(locales);
         return this;
     }
 
     @Override
     public Builder acceptLanguage(String... locales) {
         .acceptLanguage(locales);
         return this;
     }
 
    @Override
    public Builder acceptEncoding(String... encodings) {
        .acceptEncoding(encodings);
        return this;
    }
    @Override
    public Builder cookie(Cookie cookie) {
        .cookie(cookie);
        return this;
    }
    @Override
    public Builder cookie(String nameString value) {
        .cookie(namevalue);
        return this;
    }
    @Override
    public Builder cacheControl(CacheControl cacheControl) {
        .cacheControl(cacheControl);
        return this;
    }
    @Override
    public Builder header(String nameObject value) {
        .header(namevalue);
        return this;
    }
    @Override
    public Builder headers(MultivaluedMap<StringObjectheaders) {
        .headers(headers);
        return this;
    }
    @Override
    public Builder property(String nameObject value) {
        .property(namevalue);
        return this;
    }
    // Suspendable Functions
    @Override
    @Suspendable
    public Response get() {
        return method();
    }
    @Override
    @Suspendable
    public <T> T get(Class<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public <T> T get(GenericType<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public Response put(final Entity<?> entity) {
        return method(,entity);
    }
    @Override
    @Suspendable
    public <T> T put(final Entity<?> entityClass<T> responseType) {
        return method(,entity,responseType);
    }
    @Override
    @Suspendable
    public <T> T put(final Entity<?> entityGenericType<T> responseType) {
        return method(,entity,responseType);
    }
    @Override
    @Suspendable
    public Response post(final Entity<?> entity) {
        return method(,entity);
    }
    @Override
    @Suspendable
    public <T> T post(final Entity<?> entityClass<T> responseType) {
        return method(,entity,responseType);
    }
    @Override
    @Suspendable
    public <T> T post(final Entity<?> entityGenericType<T> responseType) {
        return method(,entity,responseType);
    }
    @Override
    @Suspendable
    public Response delete() {
        return method();
    }
    @Override
    @Suspendable
    public <T> T delete(Class<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public <T> T delete(GenericType<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public Response head() {
        return method();
    }
    @Override
    @Suspendable
    public Response options() {
        return method();
    }
    @Override
    @Suspendable
    public <T> T options(Class<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public <T> T options(GenericType<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public Response trace() {
        return method();
    }
    @Override
    @Suspendable
    public <T> T trace(Class<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public <T> T trace(GenericType<T> responseType) {
        return method(,responseType);
    }
    @Override
    @Suspendable
    public Response method(final String name) {
        try {
            return new AsyncRs<Response>() {
                @Override
                protected Void requestAsync() {
                    .async().method(namethis);
                    return null;
                }
            }.run();
        } catch (SuspendExecution ex) {
            throw new AssertionError(ex);
        }
    }
    @Override
    @Suspendable
    public <T> T method(final String nameClass<T> responseType) {
        try {
            return new AsyncRs<T>() {
                @Override
                protected Void requestAsync() {
                    .async().method(namethis);
                    return null;
                }
            }.run();
        } catch (SuspendExecution ex) {
            throw new AssertionError(ex);
        }
    }
    @Override
    @Suspendable
    public <T> T method(String nameGenericType<T> responseType) {
        return this.method(name, (Class<T>)responseType.getRawType());
    }
    @Override
    @Suspendable
    public Response method(final String namefinal Entity<?> entity) {
        try {
            return new AsyncRs<Response>() {
                @Override
                protected Void requestAsync() {
                    .async().method(nameentitythis);
                    return null;
                }
            }.run();
        } catch (SuspendExecution ex) {
            throw new AssertionError(ex);
        }
    }
    @Override
    @Suspendable
    public <T> T method(final String namefinal Entity<?> entityClass<T> responseType) {
        try {
            return new AsyncRs<T>() {
                @Override
                protected Void requestAsync() {
                    .async().method(nameentitythis);
                    return null;
                }
            }.run();
        } catch (SuspendExecution ex) {
            throw new AssertionError(ex);
        }
    }
    @Override
    @Suspendable
    public <T> T method(final String namefinal Entity<?> entityGenericType<T> responseType) {
        try {
            return new AsyncRs<T>() {
                @Override
                protected Void requestAsync() {
                    .async().method(nameentitythis);
                    return null;
                }
            }.run();
        } catch (SuspendExecution ex) {
            throw new AssertionError(ex);
        }
    }
    // Delegations
    @Override
    public AsyncInvoker async() {
        return .async();
    }
    @Override
    public int hashCode() {
        return .hashCode();
    }
    @Override
    public boolean equals(Object obj) {
        return .equals(obj);
    }
    @Override
    public String toString() {
        return .toString();
    }
New to GrepCode? Check out our FAQ X