RxPromise (Grails 7.0.0-SNAPSHOT)

org.grails.async.factory.rxjava3.RxPromise

All Implemented Interfaces and Traits:: Promise<T>

@groovy.transform.AutoFinal
@groovy.transform.CompileStatic
@groovy.transform.PackageScope
class RxPromise<T>
extends java.lang.Object
implements Promise<T>

Promise based on RxJava 3.x

Since:: 7.0

Nested Class Summary

Nested classes
Modifiers	Name	Description
`class`	`RxPromise.1`

Field Summary

Fields
Modifiers	Name	Description
`protected boolean`	`finished`
`protected io.reactivex.rxjava3.core.Observable<T>`	`observable`
`protected RxPromiseFactory`	`promiseFactory`
`protected io.reactivex.rxjava3.subjects.Subject<T>`	`subject`
`protected io.reactivex.disposables.Disposable`	`subscription`

Constructor Summary

Constructors
Constructor and description
`RxPromise(RxPromiseFactory promiseFactory, groovy.lang.Closure callable, rx.Scheduler scheduler)`
`RxPromise(RxPromiseFactory promiseFactory, rx.Observable single)`
`RxPromise(RxPromiseFactory promiseFactory, rx.Single single)`
`RxPromise(RxPromiseFactory promiseFactory, rx.Single single, rx.subjects.Subject subject)`
`RxPromise(RxPromiseFactory promiseFactory, rx.Observable observable, rx.subjects.Subject subject)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`Promise<T>`	`accept(T value)`
	`boolean`	`cancel(boolean mayInterruptIfRunning)`
	`T`	`get()`
	`T`	`get(long timeout, java.util.concurrent.TimeUnit unit)`
	`boolean`	`isCancelled()`
	`boolean`	`isDone()`
	`Promise<T>`	`onComplete(groovy.lang.Closure<T> callable)`
	`Promise<T>`	`onError(groovy.lang.Closure<T> callable)`
	`static java.lang.Object`	`runCallable(groovy.lang.Closure callable)`
	`Promise<T>`	`then(groovy.lang.Closure<T> callable)`
	`io.reactivex.rxjava3.core.Observable<T>`	`toObservable()`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - protected boolean finished
  - protected final io.reactivex.rxjava3.core.Observable<T> observable
  - protected final RxPromiseFactory promiseFactory
  - protected final io.reactivex.rxjava3.subjects.Subject<T> subject
  - protected io.reactivex.disposables.Disposable subscription
- Constructor Detail
  - RxPromise(RxPromiseFactory promiseFactory, groovy.lang.Closure callable, rx.Scheduler scheduler)
  - RxPromise(RxPromiseFactory promiseFactory, rx.Observable single)
  - RxPromise(RxPromiseFactory promiseFactory, rx.Single single)
  - RxPromise(RxPromiseFactory promiseFactory, rx.Single single, rx.subjects.Subject subject)
  - RxPromise(RxPromiseFactory promiseFactory, rx.Observable observable, rx.subjects.Subject subject)
- Method Detail
  - @java.lang.Override
    Promise<T> accept(T value)
  - @java.lang.Override
    boolean cancel(boolean mayInterruptIfRunning)
  - @java.lang.Override
    T get()
  - @java.lang.Override
    T get(long timeout, java.util.concurrent.TimeUnit unit)
  - @java.lang.Override
    boolean isCancelled()
  - @java.lang.Override
    boolean isDone()
  - @java.lang.Override
    Promise<T> onComplete(groovy.lang.Closure<T> callable)
  - @java.lang.Override
    Promise<T> onError(groovy.lang.Closure<T> callable)
  - static java.lang.Object runCallable(groovy.lang.Closure callable)
  - @java.lang.Override
    Promise<T> then(groovy.lang.Closure<T> callable)
  - io.reactivex.rxjava3.core.Observable<T> toObservable()

| Detail:
Field
Constructor
Method

Groovy Documentation

[Groovy] Class RxPromise<T>

Nested Class Summary

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected boolean finished

protected final io.reactivex.rxjava3.core.Observable<T> observable

protected final RxPromiseFactory promiseFactory

protected final io.reactivex.rxjava3.subjects.Subject<T> subject

protected io.reactivex.disposables.Disposable subscription

Constructor Detail

RxPromise(RxPromiseFactory promiseFactory, groovy.lang.Closure callable, rx.Scheduler scheduler)

RxPromise(RxPromiseFactory promiseFactory, rx.Observable single)

RxPromise(RxPromiseFactory promiseFactory, rx.Single single)

RxPromise(RxPromiseFactory promiseFactory, rx.Single single, rx.subjects.Subject subject)

RxPromise(RxPromiseFactory promiseFactory, rx.Observable observable, rx.subjects.Subject subject)

Method Detail

@java.lang.Override
Promise<T> accept(T value)

@java.lang.Override
boolean cancel(boolean mayInterruptIfRunning)

@java.lang.Override
T get()

@java.lang.Override
T get(long timeout, java.util.concurrent.TimeUnit unit)

@java.lang.Override
boolean isCancelled()

@java.lang.Override
boolean isDone()

@java.lang.Override
Promise<T> onComplete(groovy.lang.Closure<T> callable)

@java.lang.Override
Promise<T> onError(groovy.lang.Closure<T> callable)

static java.lang.Object runCallable(groovy.lang.Closure callable)

@java.lang.Override
Promise<T> then(groovy.lang.Closure<T> callable)

io.reactivex.rxjava3.core.Observable<T> toObservable()

[Groovy] Class RxPromise<T>

Nested Class Summary

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected boolean finished

protected final io.reactivex.rxjava3.core.Observable<T> observable

protected final RxPromiseFactory promiseFactory

protected final io.reactivex.rxjava3.subjects.Subject<T> subject

protected io.reactivex.disposables.Disposable subscription

Constructor Detail

RxPromise(RxPromiseFactory promiseFactory, groovy.lang.Closure callable, rx.Scheduler scheduler)

RxPromise(RxPromiseFactory promiseFactory, rx.Observable single)

RxPromise(RxPromiseFactory promiseFactory, rx.Single single)

RxPromise(RxPromiseFactory promiseFactory, rx.Single single, rx.subjects.Subject subject)

RxPromise(RxPromiseFactory promiseFactory, rx.Observable observable, rx.subjects.Subject subject)

Method Detail

@java.lang.OverridePromise<T> accept(T value)

@java.lang.Overrideboolean cancel(boolean mayInterruptIfRunning)

@java.lang.OverrideT get()

@java.lang.OverrideT get(long timeout, java.util.concurrent.TimeUnit unit)

@java.lang.Overrideboolean isCancelled()

@java.lang.Overrideboolean isDone()

@java.lang.OverridePromise<T> onComplete(groovy.lang.Closure<T> callable)

@java.lang.OverridePromise<T> onError(groovy.lang.Closure<T> callable)

static java.lang.Object runCallable(groovy.lang.Closure callable)

@java.lang.OverridePromise<T> then(groovy.lang.Closure<T> callable)

io.reactivex.rxjava3.core.Observable<T> toObservable()

@java.lang.Override
Promise<T> accept(T value)

@java.lang.Override
boolean cancel(boolean mayInterruptIfRunning)

@java.lang.Override
T get()

@java.lang.Override
T get(long timeout, java.util.concurrent.TimeUnit unit)

@java.lang.Override
boolean isCancelled()

@java.lang.Override
boolean isDone()

@java.lang.Override
Promise<T> onComplete(groovy.lang.Closure<T> callable)

@java.lang.Override
Promise<T> onError(groovy.lang.Closure<T> callable)

@java.lang.Override
Promise<T> then(groovy.lang.Closure<T> callable)