RxPromise (Grails 7.0.0-SNAPSHOT)

org.grails.async.factory.rxjava.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 1.x

Authors:: Graeme Rocher

Since:: 3.3

Field Summary

Fields
Modifiers	Name	Description
`protected rx.Subscription`	`subscription`

Properties Summary

Properties
Type	Name and description
`RxPromiseFactory`	`promiseFactory`
`rx.subjects.Subject<T, T>`	`subject`

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 callable)`
	`Promise<T>`	`onError(groovy.lang.Closure callable)`
	`Promise<T>`	`then(groovy.lang.Closure callable)`

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 rx.Subscription subscription
- Property Detail
  - final RxPromiseFactory promiseFactory
  - final rx.subjects.Subject<T, T> subject
- 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 callable)
  - @java.lang.Override
    Promise<T> onError(groovy.lang.Closure callable)
  - @java.lang.Override
    Promise<T> then(groovy.lang.Closure callable)

Summary:
Field
Property
Constructor
Method

Groovy Documentation

[Groovy] Class RxPromise<T>

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected rx.Subscription subscription

Property Detail

final RxPromiseFactory promiseFactory

final rx.subjects.Subject<T, T> subject

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 callable)

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

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

[Groovy] Class RxPromise<T>

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected rx.Subscription subscription

Property Detail

final RxPromiseFactory promiseFactory

final rx.subjects.Subject<T, T> subject

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 callable)

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

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

@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 callable)

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

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