Package panda.std.reactive

Class Completable<VALUE>

java.lang.Object

panda.std.reactive.Completable<VALUE>

Type Parameters:

VALUE - type of value to store

All Implemented Interfaces:

Publisher<Completable<VALUE>,VALUE>

public class Completable<VALUE>
extends Object
implements Publisher<Completable<VALUE>,VALUE>

Observable container for value that could be computed in the future. This container is similar to CompletableFuture, but without the concurrency layer.

Constructor Summary

Constructors

Constructor	Description
Completable()

Method Summary

Modifier and Type	Method	Description
Completable<VALUE>	complete(VALUE value)
static <VALUE> Completable<VALUE>	completed(VALUE value)
static <VALUE> Completable<VALUE>	create()
VALUE	get()
boolean	isReady()
boolean	isUnprepared()
<ERROR extends Exception> VALUE	orThrow(Supplier<ERROR> exception)
Completable<VALUE>	subscribe(Subscriber<? super VALUE> subscriber)
Completable<VALUE>	then(Consumer<? super VALUE> consumer)
<R> Completable<R>	thenApply(Function<? super VALUE,R> map)
<R> Completable<R>	thenCompose(Function<? super VALUE,? extends Completable<R>> map)
CompletableFuture<VALUE>	toFuture()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Completable

public Completable()

Method Details

completed

public static <VALUE> Completable<VALUE> completed(VALUE value)

create

public static <VALUE> Completable<VALUE> create()

isReady

public boolean isReady()

isUnprepared

public boolean isUnprepared()

get

public VALUE get()

orThrow

public <ERROR extends Exception> VALUE orThrow(Supplier<ERROR> exception)
                                        throws ERROR

Throws:

ERROR extends Exception

subscribe

public Completable<VALUE> subscribe(Subscriber<? super VALUE> subscriber)

Specified by:

subscribe in interface Publisher<Completable<VALUE>,VALUE>

complete

public Completable<VALUE> complete(VALUE value)

then

public Completable<VALUE> then(Consumer<? super VALUE> consumer)

thenApply

public <R> Completable<R> thenApply(Function<? super VALUE,R> map)

thenCompose

public <R> Completable<R> thenCompose(Function<? super VALUE,? extends Completable<R>> map)

toFuture

public CompletableFuture<VALUE> toFuture()