Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.rx |
Provides integration with the RxJava library.
|
Modifier and Type | Method and Description |
---|---|
static Execution |
Execution.current()
Provides the currently executing execution.
|
static ExecStarter |
Execution.fork()
Used to create a new execution.
|
static ExecController |
ExecController.require()
Returns the execution controller bound to the current thread, or throws an exception if called on a non Ratpack managed compute thread.
|
Modifier and Type | Method and Description |
---|---|
static <T> Promise<java.util.List<T>> |
RxRatpack.promise(rx.Observable.OnSubscribe<T> onSubscribe)
Converts an
Observable into a Promise , for all of the observable's items. |
static <T> Promise<java.util.List<T>> |
RxRatpack.promise(rx.Observable<T> observable)
Converts an
Observable into a Promise , for all of the observable's items. |
static <T> Promise<T> |
RxRatpack.promiseSingle(rx.Observable.OnSubscribe<T> onSubscribe)
Converts an
Observable into a Promise , for the observable's single item. |
static <T> Promise<T> |
RxRatpack.promiseSingle(rx.Observable<T> observable)
Converts an
Observable into a Promise , for the observable's single item. |