Package | Description |
---|---|
com.gigaspaces.async |
Provides GigaSpaces asynchronous operations related interfaces.
|
com.gigaspaces.internal.client.spaceproxy.executors | |
com.gigaspaces.internal.extension | |
org.openspaces.core.executor.internal | |
org.openspaces.core.executor.juc | |
org.openspaces.core.executor.support |
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
AsyncResultFilter.onResult(AsyncResultFilterEvent<T> event)
A callback invoked for each result that arrives as a result of a distributed task execution
allowing to access the result that caused this event, the events received so far, and the
total expected results.
|
static AsyncResultFilter.Decision |
AsyncResultFilter.Decision.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AsyncResultFilter.Decision[] |
AsyncResultFilter.Decision.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
GetBatchForIteratorDistributedSpaceTask.onResult(AsyncResultFilterEvent<SpaceIteratorBatchResult> event) |
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
WaitForDataDrainTask.onResult(AsyncResultFilterEvent<SpaceResponseInfo> event) |
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
InternalDistributedSpaceTaskWrapper.onResult(AsyncResultFilterEvent<T> event) |
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
RunnableDistributedTaskAdapter.onResult(AsyncResultFilterEvent<T> event)
If a filter is provided in one of the constructor methods, will delegate the call to it.
|
AsyncResultFilter.Decision |
CallableDistributedTaskAdapter.onResult(AsyncResultFilterEvent<T> event)
If a filter is provided in one of the constructor methods, will delegate the call to it.
|
Modifier and Type | Method and Description |
---|---|
AsyncResultFilter.Decision |
PrivilegedDistributedTask.onResult(AsyncResultFilterEvent<T> event)
Executes the filter (if provided) under access controls.
|
AsyncResultFilter.Decision |
AbstractDelegatingDistributedTask.onResult(AsyncResultFilterEvent<T> event) |
Copyright © GigaSpaces.