Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.handling |
The handling of application requests.
|
ratpack.http.client | |
ratpack.rx |
Provides integration with the RxJava library.
|
ratpack.test.exec |
Modifier and Type | Method and Description |
---|---|
<T> Promise<T> |
ExecControl.blocking(Callable<T> blockingOperation)
Performs a blocking operation on a separate thread, returning a promise for its value.
|
<O> Promise<O> |
PromiseOperations.blockingMap(Function<? super T,? extends O> transformer)
Like
PromiseOperations.map(Function) , but performs the transformation on a blocking thread. |
Promise<T> |
PromiseOperations.cache() |
<O> Promise<O> |
PromiseOperations.flatMap(Function<? super T,? extends Promise<O>> transformer)
Transforms the promised value by applying the given function to it that returns a promise for the transformed value.
|
<O> Promise<O> |
PromiseOperations.map(Function<? super T,? extends O> transformer)
Transforms the promised value by applying the given function to it.
|
Promise<T> |
PromiseOperations.onNull(NoArgAction action) |
<T> Promise<T> |
ExecControl.promise(Action<? super Fulfiller<T>> action)
Creates a promise for an asynchronously created value.
|
Promise<T> |
PromiseOperations.route(Predicate<? super T> predicate,
Action<? super T> action) |
Modifier and Type | Method and Description |
---|---|
<O> Promise<O> |
PromiseOperations.flatMap(Function<? super T,? extends Promise<O>> transformer)
Transforms the promised value by applying the given function to it that returns a promise for the transformed value.
|
Modifier and Type | Method and Description |
---|---|
<T> Promise<T> |
Context.blocking(Callable<T> blockingOperation)
Executes a blocking operation, returning a promise for its result.
|
<T> Promise<T> |
Context.promise(Action<? super Fulfiller<T>> action)
Creates a promise of a value that will made available asynchronously.
|
Modifier and Type | Method and Description |
---|---|
Promise<ReceivedResponse> |
HttpClient.get(Action<? super RequestSpec> action)
An asynchronous method to do a GET HTTP request, the URL and all details of the request are configured by the Action acting on the RequestSpec, but the method will be defaulted to a GET.
|
Promise<ReceivedResponse> |
HttpClient.post(Action<? super RequestSpec> action)
An asynchronous method to do a POST HTTP request, the URL and all details of the request are configured by the Action acting on the RequestSpec, but the method will be defaulted to a POST.
|
Promise<ReceivedResponse> |
HttpClient.request(Action<? super RequestSpec> action)
An asynchronous method to do a HTTP request, the URL and all details of the request are configured by the Action acting on the RequestSpec.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
RxRatpack.observe(Promise<T> promise)
Converts a Ratpack promise into an Rx observable.
|
static <T,I extends Iterable<T>> |
RxRatpack.observeEach(Promise<I> promise)
Converts a Ratpack promise of an iterable value into an Rx observable for each element of the promised iterable.
|
Modifier and Type | Method and Description |
---|---|
<T> ExecResult<T> |
ExecHarness.execute(Function<Execution,Promise<T>> func)
Synchronously returns a promised value.
|