Package org.glassfish.jersey.client

Class 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 java.lang.Object
implements javax.ws.rs.client.RxInvoker<T>
    Default implementation of 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 java.util.concurrent.ExecutorService executorService  
      private javax.ws.rs.client.SyncInvoker syncInvoker  

    • Constructor Summary

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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      T delete()  
      <R> T delete​(java.lang.Class<R> responseType)  
      <R> T delete​(javax.ws.rs.core.GenericType<R> responseType)  
      T get()  
      <R> T get​(java.lang.Class<R> responseType)  
      <R> T get​(javax.ws.rs.core.GenericType<R> responseType)  
      protected java.util.concurrent.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​(java.lang.String name)  
      <R> T method​(java.lang.String name, java.lang.Class<R> responseType)  
      T method​(java.lang.String name, javax.ws.rs.client.Entity<?> entity)  
      <R> T method​(java.lang.String name, javax.ws.rs.core.GenericType<R> responseType)  
      T options()  
      <R> T options​(java.lang.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, java.lang.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, java.lang.Class<R> clazz)  
      <R> T put​(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)  
      T trace()  
      <R> T trace​(java.lang.Class<R> responseType)  
      <R> T trace​(javax.ws.rs.core.GenericType<R> responseType)  

      • Methods inherited from class java.lang.Object

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

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

        method, method

    • Field Detail

      • syncInvoker

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

      • executorService

        private final java.util.concurrent.ExecutorService executorService

    • Constructor Detail

      • AbstractRxInvoker

        public AbstractRxInvoker​(javax.ws.rs.client.SyncInvoker syncInvoker,
                         java.util.concurrent.ExecutorService executor)

    • Method Detail

      • getSyncInvoker

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

      • getExecutorService

        protected java.util.concurrent.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​(java.lang.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,
                 java.lang.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,
                  java.lang.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​(java.lang.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​(java.lang.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​(java.lang.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​(java.lang.String name)
        Specified by:
        method in interface javax.ws.rs.client.RxInvoker<T>

      • method

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

      • method

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

      • method

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