Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.stream |
Support for reactive streams.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExecStarter
Starts a new
Execution . |
Modifier and Type | Method and Description |
---|---|
ExecSpec |
ExecSpec.eventLoop(EventLoop eventLoop)
Specifies that the execution must run on the given event loop.
|
ExecSpec |
ExecSpec.onComplete(Action<? super Execution> onComplete)
Specifies the completion callback for the execution.
|
ExecSpec |
ExecSpec.onError(Action<? super java.lang.Throwable> onError)
Specify the top level error handler for the execution.
|
ExecSpec |
ExecSpec.onStart(Action<? super Execution> onStart)
Specifies an action to be taken just before the execution starts.
|
ExecSpec |
ExecSpec.register(Action<? super RegistrySpec> action)
Populates the execution's registry.
|
Modifier and Type | Method and Description |
---|---|
default Promise<T> |
Promise.fork(Action<? super ExecSpec> execSpec)
Forks a new execution and subscribes to this promise, returning a promise for its value.
|
Modifier and Type | Method and Description |
---|---|
default TransformablePublisher<T> |
TransformablePublisher.fork(Action<? super ExecSpec> execConfig,
Action<? super T> disposer)
Consumes the given publisher eagerly in a forked execution, buffering results until ready to be consumed by this execution.
|
static <T> TransformablePublisher<T> |
Streams.fork(Publisher<T> publisher,
Action<? super ExecSpec> execConfig,
Action<? super T> disposer)
Consumes the given publisher eagerly in a forked execution, buffering results until ready to be consumed by this execution.
|