org.oddjob.events

Class EventOperatorBase<T>

java.lang.Object

org.oddjob.events.EventOperatorBase<T>

Type Parameters:

T - The type of the event.

All Implemented Interfaces:

EventOperator<T>

Direct Known Subclasses:

AllEvents, AnyEvents

public class EventOperatorBase<T>
extends java.lang.Object
implements EventOperator<T>

Base class for event operators.

Constructor Summary

Constructors

Constructor and Description
EventOperatorBase(java.util.function.Predicate<EventsArray<? extends T>> predicate)

Method Summary

Modifier and Type	Method and Description
Restore	start(java.util.List<? extends EventSource<? extends T>> nodes, java.util.function.Consumer<? super CompositeEvent<T>> results)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventOperatorBase

public EventOperatorBase(java.util.function.Predicate<EventsArray<? extends T>> predicate)

Method Detail

start

public Restore start(java.util.List<? extends EventSource<? extends T>> nodes,
                     java.util.function.Consumer<? super CompositeEvent<T>> results)
              throws java.lang.Exception

Specified by:

start in interface EventOperator<T>

Throws:

java.lang.Exception