Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.groovy.handling |
Groovy specific extensions to classes in the
ratpack.handling package. |
ratpack.handling |
The handling of application requests.
|
ratpack.rx |
Provides integration with the RxJava library.
|
ratpack.stream | |
ratpack.test.exec |
Modifier and Type | Method and Description |
---|---|
static ExecControl |
ExecControl.current()
Provides the execution control bound to the current thread.
|
ExecControl |
ExecController.getControl()
A singleton that can be used from any managed thread to perform asynchronous or blocking operations.
|
ExecControl |
Execution.getControl() |
Modifier and Type | Interface and Description |
---|---|
interface |
GroovyContext
Subclass of
Context that adds Groovy friendly variants of methods. |
Modifier and Type | Interface and Description |
---|---|
interface |
Context
The context of an individual
Handler invocation. |
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
RxRatpack.forkAndJoin(ExecControl execControl,
Observable<T> source)
Forks the current execution in order to subscribe to the given source, then joining the original execution with the source values.
|
static <T> Observable.Operator<T,T> |
RxRatpack.forkOnNext(ExecControl execControl)
An operator to parallelize an observable stream by forking a new execution for each omitted item.
|
static <T> Observable<T> |
RxRatpack.forkOnNext(ExecControl execControl,
Observable<T> observable)
Alternative method for forking the execution to process each observable element.
|
Modifier and Type | Method and Description |
---|---|
default Promise<T> |
TransformablePublisher.toPromise(ExecControl execControl)
|
static <T> Promise<T> |
Streams.toPromise(ExecControl execControl,
org.reactivestreams.Publisher<T> publisher)
Creates a promise for the given publisher's single item.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExecHarness
A utility for testing asynchronous support/service code.
|
Modifier and Type | Method and Description |
---|---|
ExecControl |
ExecHarness.getControl()
The execution control for the harness.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecHarness.run(Action<? super ExecControl> action)
Initiates an execution and blocks until it completes.
|
static void |
ExecHarness.runSingle(Action<? super ExecControl> action)
Convenient form of
ExecHarness.run(Action) that creates and closes a harness for the run. |
<T> ExecResult<T> |
ExecHarness.yield(Function<ExecControl,Promise<T>> func)
Synchronously returns a promised value.
|
static <T> ExecResult<T> |
ExecHarness.yieldSingle(Function<ExecControl,Promise<T>> func)
Creates an exec harness,
executes the given function with it before closing it, then returning execution result. |