Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.exec.util | |
ratpack.file |
Types for dealing with the file system and serving files.
|
ratpack.func |
General functional (i.e. Single Abstract Method) types.
|
ratpack.http.client |
The HTTP client.
|
ratpack.jdbctx | |
ratpack.pac4j |
Integration with pac4j for authentication/authorization.
|
ratpack.rx |
Provides integration with the RxJava library.
|
ratpack.rx2 |
Provides integration with the RxJava library.
|
ratpack.session |
Objects for providing
Session support. |
ratpack.test.exec |
Modifier and Type | Method and Description |
---|---|
default Operation |
Operation.blockingNext(Block operation)
Executes the given block as an operation, on a blocking thread.
|
default Operation |
Promise.flatOp(Function<? super T,? extends Operation> function)
Converts this promise to an operation, which is the return of
function . |
static Operation |
Operation.flatten(Factory<Operation> factory)
Create an operation that delegates to another operation.
|
default Operation |
Operation.mapError(Action<? super java.lang.Throwable> action)
Convert an error to a success or different error.
|
default Operation |
Operation.next(Block operation) |
default Operation |
Operation.next(Operation operation) |
static Operation |
Operation.noop() |
static Operation |
Operation.of(Block block) |
Operation |
Operation.onError(Action<? super java.lang.Throwable> onError) |
static Operation |
Blocking.op(Block block) |
default Operation |
Promise.operation()
Converts this promise to an operation, by effectively discarding the result.
|
default Operation |
Promise.operation(Action<? super T> action)
Converts this promise to an operation which is effectively
action . |
static Operation |
Execution.sleep(java.time.Duration duration)
Creates a sleep operation.
|
default Operation |
Operation.wiretap(Action<? super java.util.Optional<? extends java.lang.Throwable>> action) |
Modifier and Type | Method and Description |
---|---|
default Promise<T> |
Promise.close(Operation closer)
Like
Promise.close(AutoCloseable) , but allows async close operations. |
default Operation |
Operation.next(Operation operation) |
default void |
ExecStarter.start(Operation operation)
Starts the execution, and executes the given operation.
|
Modifier and Type | Method and Description |
---|---|
default Operation |
Promise.flatOp(Function<? super T,? extends Operation> function)
Converts this promise to an operation, which is the return of
function . |
static Operation |
Operation.flatten(Factory<Operation> factory)
Create an operation that delegates to another operation.
|
default Promise<T> |
Promise.nextOp(Function<? super T,? extends Operation> function)
Executes the operation returned by the given function.
|
default Promise<T> |
Promise.nextOpIf(Predicate<? super T> predicate,
Function<? super T,? extends Operation> function)
Executes the operation returned by the given function, if it satisfies the predicate.
|
default <O> O |
Operation.to(Function<? super Operation,? extends O> function) |
Modifier and Type | Method and Description |
---|---|
Operation |
ParallelBatch.forEach(BiAction<? super java.lang.Integer,? super T> consumer)
Processes the promises of the batch, stopping at the first error, emitting results to the given callback.
|
Operation |
Batch.forEach(BiAction<? super java.lang.Integer,? super T> consumer)
Processes the promises of the batch, stopping at the first error, emitting results to the given callback.
|
Operation |
SerialBatch.forEach(BiAction<? super java.lang.Integer,? super T> consumer)
Processes the promises of the batch, stopping at the first error, emitting results to the given callback.
|
Modifier and Type | Method and Description |
---|---|
static Operation |
FileIo.write(io.netty.buffer.ByteBuf bytes,
long position,
Promise<? extends java.nio.channels.AsynchronousFileChannel> file)
Writes the given bytes to the given file, starting at the given position.
|
static Operation |
FileIo.write(io.netty.buffer.ByteBuf bytes,
Promise<? extends java.nio.channels.AsynchronousFileChannel> file)
Writes the given bytes to the given file, starting at the start.
|
Modifier and Type | Method and Description |
---|---|
default Operation |
Block.operation()
Deprecated.
since 1.5
|
Modifier and Type | Method and Description |
---|---|
HttpClientSpec |
HttpClientSpec.responseIntercept(Operation operation)
Execute the provide
Operation for all responses returned by this client. |
Modifier and Type | Method and Description |
---|---|
Operation |
Transaction.begin()
Starts a transaction.
|
Operation |
Transaction.commit()
Commits the transaction, or pops the most recent savepoint off the stack.
|
Operation |
Transaction.rollback()
Initiates a transaction rollback.
|
Operation |
Transaction.wrap(Operation operation)
Decorates the given operation in a transaction boundary.
|
Modifier and Type | Method and Description |
---|---|
Operation |
Transaction.wrap(Operation operation)
Decorates the given operation in a transaction boundary.
|
Modifier and Type | Method and Description |
---|---|
static Operation |
RatpackPac4j.logout(Context ctx)
Logs out the current user, removing their profile from the session.
|
Modifier and Type | Method and Description |
---|---|
static Observable<java.lang.Void> |
RxRatpack.observe(Operation operation)
Converts a
Operation into an Observable . |
Modifier and Type | Method and Description |
---|---|
static Completable |
RxRatpack.complete(Operation operation)
Converts a
Operation into a Completable . |
Modifier and Type | Method and Description |
---|---|
default Operation |
Session.clear()
A convenience shorthand for
SessionData.clear() . |
Operation |
SessionStore.remove(io.netty.util.AsciiString sessionId)
Removes the session data for the given id.
|
default Operation |
Session.remove(java.lang.Class<?> type)
A convenience shorthand for
SessionData.remove(Class) . |
default Operation |
Session.remove(SessionKey<?> key)
A convenience shorthand for
SessionData.remove(SessionKey) . |
default Operation |
Session.remove(java.lang.String name)
A convenience shorthand for
SessionData.remove(String) . |
default Operation |
SessionData.save()
See
Session.save() . |
Operation |
Session.save()
Persists the session data.
|
default <T> Operation |
Session.set(java.lang.Class<T> type,
T value)
A convenience shorthand for
SessionData.set(Class, Object) . |
default <T> Operation |
Session.set(java.lang.Class<T> type,
T value,
SessionSerializer serializer)
A convenience shorthand for
SessionData.set(Class, Object, SessionSerializer) . |
default <T> Operation |
Session.set(SessionKey<T> key,
T value)
A convenience shorthand for
SessionData.set(SessionKey, Object) . |
default <T> Operation |
Session.set(SessionKey<T> key,
T value,
SessionSerializer serializer)
A convenience shorthand for
SessionData.set(SessionKey, Object, SessionSerializer) . |
default <T> Operation |
Session.set(java.lang.String name,
T value)
A convenience shorthand for
SessionData.set(String, Object) . |
default <T> Operation |
Session.set(java.lang.String name,
T value,
SessionSerializer serializer)
A convenience shorthand for
SessionData.set(String, Object, SessionSerializer) . |
default <T> Operation |
Session.set(T value)
A convenience shorthand for
SessionData.set(Object) . |
default <T> Operation |
Session.set(T value,
SessionSerializer serializer)
A convenience shorthand for
SessionData.set(Object, SessionSerializer) . |
Operation |
SessionStore.store(io.netty.util.AsciiString sessionId,
io.netty.buffer.ByteBuf sessionData)
Writes the session data for the given id.
|
default Operation |
SessionData.terminate()
See
Session.terminate() . |
Operation |
Session.terminate()
Terminates the session and session id.
|
Modifier and Type | Method and Description |
---|---|
default void |
ExecHarness.execute(Operation operation) |
static void |
ExecHarness.executeSingle(Operation operation) |
Modifier and Type | Method and Description |
---|---|
default void |
ExecHarness.execute(Function<? super Execution,? extends Operation> function) |
static void |
ExecHarness.executeSingle(Function<? super Execution,? extends Operation> function) |