com.gigaspaces.async
Interface AsyncResultFilter<T>

All Known Implementing Classes:

AbstractDelegatingDistributedTask, AvgTask, CallableDistributedTaskAdapter, MaxTask, MinTask, PrivilegedDistributedTask, RunnableDistributedTaskAdapter, SimpleDelegatingDistributedTask, SumTask

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

static class

AsyncResultFilter.Decision Controls what should be done with the results.

Method Summary

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.