Modifier and Type | Class and Description |
---|---|
class |
ConcurrentCompletable<T>
A concurrent implementation of
Completable . |
Modifier and Type | Method and Description |
---|---|
<T> Completable<T> |
CoreAsync.completable() |
<T> Completable<T> |
Async.completable()
Build a new resolvable completable.
|
Modifier and Type | Method and Description |
---|---|
<C> Stage<C> |
CoreAsync.doCall(Callable<? extends C> callable,
ExecutorService executor,
Completable<C> stage) |
Constructor and Description |
---|
DelayedCollectCoordinator(Caller caller,
Collection<? extends Callable<? extends Stage<? extends S>>> callables,
Consumer<S> consumer,
Supplier<T> supplier,
Completable<? super T> future,
int parallelism) |
RetryCallHelper(long start,
ScheduledExecutorService scheduler,
Callable<? extends Stage<? extends T>> callable,
Supplier<RetryDecision> policyInstance,
Completable<T> future,
ClockSource clockSource) |
Copyright © 2017. All rights reserved.