| 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.