Modifier and Type | Class and Description |
---|---|
class |
DirectCaller
An abstract implementation of a caller that invokes the handles directly in the calling thread.
|
class |
ExecutorCaller
A
Caller implementation that defers all execution to a
ExecutorService . |
class |
PrintStreamCaller
The simplest possible implementation of a concurrent caller.
|
class |
RecursionSafeCaller
A
Caller implementation that implements immediate calling, and provides a fallback to
avoid blowing up the stack when operations are recursively called. |
Modifier and Type | Method and Description |
---|---|
Caller |
CoreAsync.caller() |
Modifier and Type | Method and Description |
---|---|
CoreAsync.Builder |
CoreAsync.Builder.caller(Caller caller)
Specify an asynchronous caller implementation.
|
static <T> ConcurrentManaged<T> |
ConcurrentManaged.newManaged(Async async,
Caller caller,
ManagedOptions options,
Supplier<? extends Stage<T>> setup,
Function<? super T,? extends Stage<Void>> teardown) |
Constructor and Description |
---|
ConcurrentCompletable(Caller caller)
Setup a concurrent completable that uses a custom caller implementation.
|
DelayedCollectCoordinator(Caller caller,
Collection<? extends Callable<? extends Stage<? extends S>>> callables,
Consumer<S> consumer,
Supplier<T> supplier,
Completable<? super T> future,
int parallelism) |
ImmediateCancelled(Caller caller) |
ImmediateCompleted(Caller caller,
T result) |
ImmediateFailed(Caller caller,
Throwable cause) |
RecursionSafeCaller(ExecutorService executorService,
Caller caller) |
RecursionSafeCaller(ExecutorService executorService,
Caller caller,
long maxRecursionDepth) |
Copyright © 2017. All rights reserved.