Interface AsyncResultFilter<T>

All Known Implementing Classes:
AbstractDelegatingDistributedTask, AvgTask, CallableDistributedTaskAdapter, GetBatchForIteratorDistributedSpaceTask, InternalDistributedSpaceTaskWrapper, InternalDurableTaskWrapper, 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
    Description
    static enum 
    AsyncResultFilter.Decision
    Controls what should be done with the results.

  • Method Summary

    Modifier and Type
    Method
    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 Details

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