org.glassfish.jersey.client.rx.jsr166e

Class RxCompletableFuture

java.lang.Object

org.glassfish.jersey.client.rx.jsr166e.RxCompletableFuture

public final class RxCompletableFuture
extends Object

Main entry point to the Reactive Client API used to bootstrap reactive client or reactive client target instances based on JSR-166e's (pre-Java 8) completable future.

Since:

2.13

Author:

Michal Gajdos

See Also:

Rx

Method Summary

Methods

Modifier and Type	Method and Description
static RxClient<RxCompletableFutureInvoker>	from(Client client) Create a new reactive client instance initialized with given JAX-RS client instance and parametrized with invoker based on the completable future from JSR-166e (pre-Java 8).
static RxClient<RxCompletableFutureInvoker>	from(Client client, ExecutorService executor) Create a new reactive client instance initialized with given JAX-RS client instance and parametrized with invoker based on the completable future from JSR-166e (pre-Java 8).
static RxWebTarget<RxCompletableFutureInvoker>	from(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 completable future from JSR-166e (pre-Java 8).
static RxWebTarget<RxCompletableFutureInvoker>	from(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 completable future from JSR-166e (pre-Java 8).
static RxClient<RxCompletableFutureInvoker>	newClient() Create a new reactive client instance parametrized with invoker based on the completable future from JSR-166e (pre-Java 8).
static RxClient<RxCompletableFutureInvoker>	newClient(ExecutorService executor) Create a new reactive client instance parametrized with invoker based on the completable future from JSR-166e (pre-Java 8).

Methods inherited from class java.lang.Object

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

Method Detail

newClient

public static RxClient<RxCompletableFutureInvoker> newClient()

Create a new reactive client instance parametrized with invoker based on the completable future from JSR-166e (pre-Java 8). Reactive requests, invoked using rx(...) methods, are executed via "common 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.

Returns:

new reactive client extension.

See Also:

Rx.newClient(Class)

newClient

public static RxClient<RxCompletableFutureInvoker> newClient(ExecutorService executor)

Create a new reactive client instance parametrized with invoker based on the completable future from JSR-166e (pre-Java 8). 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.

Parameters:

executor - the executor service to execute reactive requests.

Returns:

new reactive client extension.

See Also:

Rx.newClient(Class, java.util.concurrent.ExecutorService)

from

public static RxClient<RxCompletableFutureInvoker> from(Client client)

Create a new reactive client instance initialized with given JAX-RS client instance and parametrized with invoker based on the completable future from JSR-166e (pre-Java 8). Reactive requests, invoked using rx(...) methods, are executed via "common thread pool" service.

Parameters:

client - the JAX-RS client used to initialize new reactive client extension.

Returns:

new reactive client extension.

See Also:

Rx.from(javax.ws.rs.client.Client, Class)

from

public static RxClient<RxCompletableFutureInvoker> from(Client client,
                                        ExecutorService executor)

Create a new reactive client instance initialized with given JAX-RS client instance and parametrized with invoker based on the completable future from JSR-166e (pre-Java 8). Reactive requests, invoked using rx(...) method, are executed via given executor service.

Parameters:

client - the JAX-RS client used to initialize new reactive client extension.

executor - the executor service to execute reactive requests.

Returns:

new reactive client extension.

See Also:

Rx.from(javax.ws.rs.client.Client, Class, java.util.concurrent.ExecutorService)

from

public static RxWebTarget<RxCompletableFutureInvoker> from(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 completable future from JSR-166e (pre-Java 8). Reactive requests, invoked using rx(...) methods, are executed via "common thread pool" service.

Parameters:

target - the JAX-RS client target used to initialize new reactive client target extension.

Returns:

new reactive client target extension.

See Also:

Rx.from(javax.ws.rs.client.WebTarget, Class)

from

public static RxWebTarget<RxCompletableFutureInvoker> from(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 completable future from JSR-166e (pre-Java 8). Reactive requests, invoked using rx(...) method, are executed via given executor service.

Parameters:

target - the JAX-RS client target used to initialize new reactive client target extension.

executor - the executor service to execute reactive requests.

Returns:

new reactive client target extension.

See Also:

Rx.from(javax.ws.rs.client.WebTarget, Class, java.util.concurrent.ExecutorService)