com.gigaspaces.async

Interface AsyncResultFilter<T>

All Known Implementing Classes:

AbstractDelegatingDistributedTask, AvgTask, CallableDistributedTaskAdapter, GetBatchForIteratorDistributedSpaceTask, InternalDistributedSpaceTaskWrapper, MaxTask, MinTask, PrivilegedDistributedTask, RunnableDistributedTaskAdapter, SimpleDelegatingDistributedTask, SumTask, WaitForDataDrainTask

public interface AsyncResultFilter<T>

An optional filter that can be used with distributed tasks. Allows to be notified for each AsyncResult that arrives and decide what should be done with it.

Since:

6.6

Author:

Assaf Ronen

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	AsyncResultFilter.Decision Controls what should be done with the results.

Method Summary

Modifier and Type	Method and Description
AsyncResultFilter.Decision	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.

Method Detail

onResult

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