Package | Description |
---|---|
com.gigaspaces.async |
Provides GigaSpaces asynchronous operations related interfaces.
|
org.openspaces.core.executor.juc | |
org.openspaces.core.executor.support | |
org.openspaces.events.support | |
org.openspaces.remoting |
A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting
integrations.
|
Modifier and Type | Method and Description |
---|---|
AsyncResult<T> |
AsyncResultFilterEvent.getCurrentResult()
Returns the current result that caused this event.
|
AsyncResult<T>[] |
AsyncResultFilterEvent.getReceivedResults()
Returns the received results without the current result.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncFutureListener.onResult(AsyncResult<T> result)
A callback when a result of an async invocation arrives.
|
Modifier and Type | Method and Description |
---|---|
R |
AsyncResultsReducer.reduce(List<AsyncResult<T>> results) |
Constructor and Description |
---|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
Modifier and Type | Method and Description |
---|---|
R |
CallableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
R |
RunnableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
Modifier and Type | Method and Description |
---|---|
void |
WaitForAllListener.onResult(AsyncResult<T> result) |
void |
WaitForAnyListener.onResult(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
R |
AvgReducer.reduce(List<AsyncResult<T>> results) |
R |
AvgTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
T |
MaxReducer.reduce(List<AsyncResult<T>> results) |
T |
MaxTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
T |
MinReducer.reduce(List<AsyncResult<T>> results) |
T |
MinTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
R |
PrivilegedDistributedTask.reduce(List<AsyncResult<T>> results)
Reduces the provided task under access controls.
|
R |
SimpleDelegatingDistributedTask.reduce(List<AsyncResult<T>> asyncResults) |
R |
SumReducer.reduce(List<AsyncResult<T>> results) |
R |
SumTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
Constructor and Description |
---|
AsyncResultFuture(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
Boolean |
UnregisterDistributedEventContainerTask.reduce(List<AsyncResult<Boolean>> results) |
Object |
RegisterDistributedEventContainerTask.reduce(List<AsyncResult<Serializable>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Copyright © GigaSpaces.