com.hammurapi.eventbus
Class PredicateChainingMatcher.EventBusJoiner
java.lang.Object
com.hammurapi.eventbus.PredicateChainingMatcher.EventBusJoiner
- Enclosing class:
- PredicateChainingMatcher<E,P extends Comparable<P>,C,K,H extends EventBus.Handle<E,P,C>,S extends EventStore<E,P,C,H,S>>
protected abstract class PredicateChainingMatcher.EventBusJoiner
- extends
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PredicateChainingMatcher.EventBusJoiner
protected PredicateChainingMatcher.EventBusJoiner([] inputCollectors,
Class<AbstractEventBus.Handle<E,P,C,K>[]> inputType,
boolean outerJoin)
takeSnapshot
protected abstract void takeSnapshot(K joinNodeId,
AbstractEventBus.Snapshot<E,P,C,K,H,S> snapshot,
Set<K> taken)