public final class RxListenableFuture extends Object
reactive client
or reactive client target
instances based on Guava's
listenable future
.Rx
Modifier and Type | Method and Description |
---|---|
static RxClient<RxListenableFutureInvoker> |
from(javax.ws.rs.client.Client client)
Create a new
reactive client instance initialized with given JAX-RS client
instance and parametrized with invoker based on the listenable future from Guava. |
static RxClient<RxListenableFutureInvoker> |
from(javax.ws.rs.client.Client client,
ExecutorService executor)
Create a new
reactive client instance initialized with given JAX-RS client
instance and parametrized with invoker based on the listenable future from Guava. |
static RxWebTarget<RxListenableFutureInvoker> |
from(javax.ws.rs.client.WebTarget target)
Create a new
reactive client target instance initialized with given
JAX-RS client web target instance and parametrized with invoker based on the
listenable future from Guava. |
static RxWebTarget<RxListenableFutureInvoker> |
from(javax.ws.rs.client.WebTarget target,
ExecutorService executor)
Create a new
reactive client target instance initialized with given
JAX-RS client web target instance and parametrized with invoker based on the
listenable future from Guava. |
static RxClient<RxListenableFutureInvoker> |
newClient()
Create a new
reactive client instance parametrized with invoker based on
the listenable future from Guava. |
static RxClient<RxListenableFutureInvoker> |
newClient(ExecutorService executor)
Create a new
reactive client instance parametrized with invoker based on
the listenable future from Guava. |
public static RxClient<RxListenableFutureInvoker> newClient()
reactive client
instance parametrized with invoker based on
the listenable future
from Guava. Reactive requests,
invoked using rx(...)
methods, are executed via
"new thread pool" service
.
Instance is initialized with a JAX-RS client created using the default client builder implementation class provided by the
JAX-RS implementation provider.Rx.newClient(Class)
public static RxClient<RxListenableFutureInvoker> newClient(ExecutorService executor)
reactive client
instance parametrized with invoker based on
the listenable future
from Guava. Reactive requests,
invoked using rx(...)
method, are executed via given
executor service
.
Instance is initialized with a JAX-RS client created using the default client builder implementation class provided by the
JAX-RS implementation provider.executor
- the executor service to execute reactive requests.Rx.newClient(Class, java.util.concurrent.ExecutorService)
public static RxClient<RxListenableFutureInvoker> from(javax.ws.rs.client.Client client)
reactive client
instance initialized with given JAX-RS client
instance and parametrized with invoker based on the listenable future
from Guava. Reactive requests, invoked using
rx(...)
methods, are executed via
"new thread pool" service
.client
- the JAX-RS client used to initialize new reactive client extension.Rx.from(javax.ws.rs.client.Client, Class)
public static RxClient<RxListenableFutureInvoker> from(javax.ws.rs.client.Client client, ExecutorService executor)
reactive client
instance initialized with given JAX-RS client
instance and parametrized with invoker based on the listenable future
from Guava. Reactive requests, invoked using
rx(...)
method, are executed via given
executor service
.client
- the JAX-RS client used to initialize new reactive client extension.executor
- the executor service to execute reactive requests.Rx.from(javax.ws.rs.client.Client, Class, java.util.concurrent.ExecutorService)
public static RxWebTarget<RxListenableFutureInvoker> from(javax.ws.rs.client.WebTarget target)
reactive client target
instance initialized with given
JAX-RS client web target instance and parametrized with invoker based on the
listenable future
from Guava. Reactive requests, invoked using
rx(...)
methods, are executed via
"new thread pool" service
.target
- the JAX-RS client target used to initialize new reactive client target extension.Rx.from(javax.ws.rs.client.WebTarget, Class)
public static RxWebTarget<RxListenableFutureInvoker> from(javax.ws.rs.client.WebTarget target, ExecutorService executor)
reactive client target
instance initialized with given
JAX-RS client web target instance and parametrized with invoker based on the
listenable future
from Guava. Reactive requests, invoked using
rx(...)
method, are executed via given
executor service
.target
- the JAX-RS client target used to initialize new reactive client target extension.executor
- the executor service to execute reactive requests.Rx.from(javax.ws.rs.client.WebTarget, Class, java.util.concurrent.ExecutorService)
Copyright © 2007-2015, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.