Class AbstractRxInvoker<T>

java.lang.Object
org.glassfish.jersey.client.AbstractRxInvoker<T>
Type Parameters:
T - the asynchronous/event-based completion aware type. The given type should be parametrized with the actual response type.
All Implemented Interfaces:
javax.ws.rs.client.RxInvoker<T>
Direct Known Subclasses:
JerseyCompletionStageRxInvoker
public abstract class AbstractRxInvoker<T> extends Object implements javax.ws.rs.client.RxInvoker<T>
Default implementation of
invalid reference 
reactive invoker
. Extensions of this class are supposed to implement RxInvoker.method(String, Entity, Class) and RxInvoker.method(String, Entity, GenericType) methods to which implementations of the rest of the methods from the contract delegate to.
Since:
2.26

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final ExecutorService
    executorService
     
    private final javax.ws.rs.client.SyncInvoker
    syncInvoker
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractRxInvoker(javax.ws.rs.client.SyncInvoker syncInvoker, ExecutorService executor)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    delete()
     
    <R> T
    delete(Class<R> responseType)
     
    <R> T
    delete(javax.ws.rs.core.GenericType<R> responseType)
     
    T
    get()
     
    <R> T
    get(Class<R> responseType)
     
    <R> T
    get(javax.ws.rs.core.GenericType<R> responseType)
     
    protected ExecutorService
    getExecutorService()
    Return executorService service this reactive invoker was initialized with.
    protected javax.ws.rs.client.SyncInvoker
    getSyncInvoker()
    Return invocation builder this reactive invoker was initialized with.
    T
    head()
     
    T
    method(String name)
     
    <R> T
    method(String name, Class<R> responseType)
     
    T
    method(String name, javax.ws.rs.client.Entity<?> entity)
     
    <R> T
    method(String name, javax.ws.rs.core.GenericType<R> responseType)
     
    T
    options()
     
    <R> T
    options(Class<R> responseType)
     
    <R> T
    options(javax.ws.rs.core.GenericType<R> responseType)
     
    T
    post(javax.ws.rs.client.Entity<?> entity)
     
    <R> T
    post(javax.ws.rs.client.Entity<?> entity, Class<R> clazz)
     
    <R> T
    post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
     
    T
    put(javax.ws.rs.client.Entity<?> entity)
     
    <R> T
    put(javax.ws.rs.client.Entity<?> entity, Class<R> clazz)
     
    <R> T
    put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
     
    T
    trace()
     
    <R> T
    trace(Class<R> responseType)
     
    <R> T
    trace(javax.ws.rs.core.GenericType<R> responseType)
     

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface javax.ws.rs.client.RxInvoker

    method, method

  • Field Details

    • syncInvoker

      private final javax.ws.rs.client.SyncInvoker syncInvoker

    • executorService

      private final ExecutorService executorService

  • Constructor Details

    • AbstractRxInvoker

      public AbstractRxInvoker(javax.ws.rs.client.SyncInvoker syncInvoker, ExecutorService executor)

  • Method Details

    • getSyncInvoker

      protected javax.ws.rs.client.SyncInvoker getSyncInvoker()
      Return invocation builder this reactive invoker was initialized with.
      Returns:
      non-null invocation builder.

    • getExecutorService

      protected ExecutorService getExecutorService()
      Return executorService service this reactive invoker was initialized with.
      Returns:
      executorService service instance or null.

    • get

      public T get()
      Specified by:
      get in interface javax.ws.rs.client.RxInvoker<T>

    • get

      public <R> T get(Class<R> responseType)
      Specified by:
      get in interface javax.ws.rs.client.RxInvoker<T>

    • get

      public <R> T get(javax.ws.rs.core.GenericType<R> responseType)
      Specified by:
      get in interface javax.ws.rs.client.RxInvoker<T>

    • put

      public T put(javax.ws.rs.client.Entity<?> entity)
      Specified by:
      put in interface javax.ws.rs.client.RxInvoker<T>

    • put

      public <R> T put(javax.ws.rs.client.Entity<?> entity, Class<R> clazz)
      Specified by:
      put in interface javax.ws.rs.client.RxInvoker<T>

    • put

      public <R> T put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
      Specified by:
      put in interface javax.ws.rs.client.RxInvoker<T>

    • post

      public T post(javax.ws.rs.client.Entity<?> entity)
      Specified by:
      post in interface javax.ws.rs.client.RxInvoker<T>

    • post

      public <R> T post(javax.ws.rs.client.Entity<?> entity, Class<R> clazz)
      Specified by:
      post in interface javax.ws.rs.client.RxInvoker<T>

    • post

      public <R> T post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
      Specified by:
      post in interface javax.ws.rs.client.RxInvoker<T>

    • delete

      public T delete()
      Specified by:
      delete in interface javax.ws.rs.client.RxInvoker<T>

    • delete

      public <R> T delete(Class<R> responseType)
      Specified by:
      delete in interface javax.ws.rs.client.RxInvoker<T>

    • delete

      public <R> T delete(javax.ws.rs.core.GenericType<R> responseType)
      Specified by:
      delete in interface javax.ws.rs.client.RxInvoker<T>

    • head

      public T head()
      Specified by:
      head in interface javax.ws.rs.client.RxInvoker<T>

    • options

      public T options()
      Specified by:
      options in interface javax.ws.rs.client.RxInvoker<T>

    • options

      public <R> T options(Class<R> responseType)
      Specified by:
      options in interface javax.ws.rs.client.RxInvoker<T>

    • options

      public <R> T options(javax.ws.rs.core.GenericType<R> responseType)
      Specified by:
      options in interface javax.ws.rs.client.RxInvoker<T>

    • trace

      public T trace()
      Specified by:
      trace in interface javax.ws.rs.client.RxInvoker<T>

    • trace

      public <R> T trace(Class<R> responseType)
      Specified by:
      trace in interface javax.ws.rs.client.RxInvoker<T>

    • trace

      public <R> T trace(javax.ws.rs.core.GenericType<R> responseType)
      Specified by:
      trace in interface javax.ws.rs.client.RxInvoker<T>

    • method

      public T method(String name)
      Specified by:
      method in interface javax.ws.rs.client.RxInvoker<T>

    • method

      public <R> T method(String name, Class<R> responseType)
      Specified by:
      method in interface javax.ws.rs.client.RxInvoker<T>

    • method

      public <R> T method(String name, javax.ws.rs.core.GenericType<R> responseType)
      Specified by:
      method in interface javax.ws.rs.client.RxInvoker<T>

    • method

      public T method(String name, javax.ws.rs.client.Entity<?> entity)
      Specified by:
      method in interface javax.ws.rs.client.RxInvoker<T>