| Package | Description | 
|---|---|
| com.gigaspaces.async | 
 Provides GigaSpaces asynchronous operations related interfaces. 
 | 
| com.gigaspaces.async.internal | |
| com.gigaspaces.internal.client.spaceproxy.executors | |
| com.gigaspaces.internal.cluster.node.impl.replica | |
| com.gigaspaces.internal.remoting.routing.clustered | |
| com.gigaspaces.internal.space.actions | |
| com.gigaspaces.internal.space.requests | |
| org.openspaces.core.executor.internal | |
| org.openspaces.core.executor.juc | |
| org.openspaces.core.executor.support | |
| org.openspaces.core.transaction.internal | |
| 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 | Class and Description | 
|---|---|
class  | 
DefaultAsyncResult<T>
Default container for async result 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CompoundFuture.onResult(AsyncResult<T> result)  | 
| Modifier and Type | Method and Description | 
|---|---|
AddReplicationGatewayTargetResponseInfo | 
AddReplicationGatewayTargetTask.reduce(List<AsyncResult<AddReplicationGatewayTargetResponseInfo>> results)  | 
AddTypeIndexesResult | 
AddTypeIndexesTask.reduce(List<AsyncResult<AddTypeIndexesResult>> results)  | 
GetTypeDescriptorActionInfo | 
GetTypeDescriptorTask.reduce(List<AsyncResult<GetTypeDescriptorActionInfo>> results)  | 
RegisterTypeDescriptorResponseInfo | 
RegisterTypeDescriptorTask.reduce(List<AsyncResult<RegisterTypeDescriptorResponseInfo>> results)  | 
RemoveReplicationGatewayTargetResponseInfo | 
RemoveReplicationGatewayTargetTask.reduce(List<AsyncResult<RemoveReplicationGatewayTargetResponseInfo>> results)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceCopyReplicaRunnable.onResult(AsyncResult<Collection<ISpaceReplicaData>> result)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClusterRemoteOperationRouter.AsyncOperationExecutor.onResult(AsyncResult<T> asyncResult)  | 
| Modifier and Type | Method and Description | 
|---|---|
GetTypeDescriptorActionInfo | 
GetTypeDescriptorActionInfo.reduce(List<AsyncResult<GetTypeDescriptorActionInfo>> results)  | 
| Modifier and Type | Method and Description | 
|---|---|
AddTypeIndexesResult | 
AddTypeIndexesRequestInfo.reduce(List<AsyncResult<AddTypeIndexesResult>> results)  | 
RegisterReplicationLocalViewResponseInfo | 
RegisterReplicationLocalViewRequestInfo.reduce(List<AsyncResult<RegisterReplicationLocalViewResponseInfo>> results)  | 
RegisterReplicationNotificationResponseInfo | 
RegisterReplicationNotificationRequestInfo.reduce(List<AsyncResult<RegisterReplicationNotificationResponseInfo>> results)  | 
RegisterTypeDescriptorResponseInfo | 
RegisterTypeDescriptorRequestInfo.reduce(List<AsyncResult<RegisterTypeDescriptorResponseInfo>> results)  | 
RegisterReplicationLocalViewResponseInfo | 
UnregisterReplicationLocalViewRequestInfo.reduce(List<AsyncResult<SpaceResponseInfo>> results)  | 
RegisterReplicationNotificationResponseInfo | 
UnregisterReplicationNotificationRequestInfo.reduce(List<AsyncResult<SpaceResponseInfo>> results)  | 
| Modifier and Type | Method and Description | 
|---|---|
R | 
InternalDistributedSpaceTaskWrapper.reduce(List<AsyncResult<T>> asyncResults)  | 
| Modifier and Type | Method and Description | 
|---|---|
R | 
RunnableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer. 
 | 
R | 
CallableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
WaitForAnyListener.onResult(AsyncResult<T> result)  | 
void | 
WaitForAllListener.onResult(AsyncResult<T> result)  | 
| Modifier and Type | Method and Description | 
|---|---|
R | 
SimpleDelegatingDistributedTask.reduce(List<AsyncResult<T>> asyncResults)  | 
T | 
MinReducer.reduce(List<AsyncResult<T>> results)  | 
R | 
AvgTask.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 | 
SumTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal  
SumReducer. | 
R | 
SumReducer.reduce(List<AsyncResult<T>> results)  | 
T | 
MinTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal  
SumReducer. | 
T | 
MaxReducer.reduce(List<AsyncResult<T>> results)  | 
R | 
AvgReducer.reduce(List<AsyncResult<T>> results)  | 
T | 
MaxTask.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 | 
|---|---|
void | 
TransactionalAsyncFutureListener.onPostCommitTransaction(AsyncResult<T> asyncResult)  | 
void | 
TransactionalAsyncFutureListener.onPostRollbackTransaction(AsyncResult<T> asyncResult)  | 
void | 
InternalAsyncFutureListener.onResult(AsyncResult<T> asyncResult)  | 
void | 
TransactionalAsyncFutureListener.onTransactionalResult(AsyncResult<T> asyncResult,
                     org.springframework.transaction.TransactionStatus txStatus)  | 
| 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.