Modifier and Type | Class and Description |
---|---|
class |
ConcurrentCompletable<T>
A concurrent implementation of
Completable . |
class |
DelayedCollectCoordinator<S,T>
Coordinator thread for handling delayed callables executing with a given parallelism.
|
class |
RetryCallHelper<T>
A helper class for retry-until-completed behaviour.
|
Modifier and Type | Method and Description |
---|---|
Stage<T> |
ConcurrentCompletable.handle(Handle<? super T> handle) |
Stage<T> |
ImmediateCompleted.handle(Handle<? super T> handle) |
Stage<T> |
ImmediateFailed.handle(Handle<? super T> handle) |
Stage<T> |
ImmediateCancelled.handle(Handle<? super T> handle) |
Stage<T> |
Stage.handle(Handle<? super T> handle)
Register a listener that is called on all three types of events for the current stage; completed,
failed, and cancelled.
|
Copyright © 2017. All rights reserved.