A B C D E G H I J L M N O P R S T U V W

C

collectHandlers(Map<C, Map<<any>, ? super Boolean>>, ExecutorService, AtomicReference<Collection<Future<Collection<EventHandlerWrapper<E, P, C, K, H, S>>>>>, AbstractEventBus.Handle<E, P, C, K>...) - Method in class com.hammurapi.eventbus.PredicatedInferenceNode

com.hammurapi.eventbus - package com.hammurapi.eventbus

This package contains interfaces and classes which define event bus and provide foundation for implementations.

com.hammurapi.eventbus.local - package com.hammurapi.eventbus.local

This package provides local (in-JVM) implementation of EventBus.

compare(<any>, <any>) - Method in class com.hammurapi.eventbus.PredicateCostCardinalityComparator

compareTo(<any>) - Method in class com.hammurapi.eventbus.HandleExtractor

compareTo(<any>) - Method in class com.hammurapi.eventbus.MappedHandlePredicate

CompositeContext<E,P extends Comparable<P>,C,H extends EventBus.Handle<E,P,C>,S extends EventStore<E,P,C,H,S>> - Class in com.hammurapi.eventbus

CompositeContext(EventDispatchContext<E, P, C, H, S>, C, TrackingExecutorService, Queue<Conclusion<E, P, C, H>>, ExceptionHandler) - Constructor for class com.hammurapi.eventbus.CompositeContext

Conclusion<E,P extends Comparable<P>,C,H extends EventBus.Handle<E,P,C>> - Interface in com.hammurapi.eventbus

Marker interface.

consume(int) - Method in interface com.hammurapi.eventbus.EventDispatchContext

Consumes event at index removing them from further multi-event joins.

consume(E) - Method in interface com.hammurapi.eventbus.EventDispatchContext

Consumes event.

consume(int) - Method in class com.hammurapi.eventbus.EventDispatchJoinContextFilter

consume(E) - Method in class com.hammurapi.eventbus.EventDispatchJoinContextFilter

consumeJoin(int) - Method in interface com.hammurapi.eventbus.EventDispatchJoinContext

Consumes event at index removing it from further multi-event joins by this handler, but not from processing by other handlers.

consumeJoin(E) - Method in interface com.hammurapi.eventbus.EventDispatchJoinContext

Consumes event removing it from further multi-event joins by this handler, but not by other handlers.

consumeJoin(int) - Method in class com.hammurapi.eventbus.EventDispatchJoinContextFilter

consumeJoin(E) - Method in class com.hammurapi.eventbus.EventDispatchJoinContextFilter

consumes() - Method in class com.hammurapi.eventbus.AbstractEventBus.JoinInputEventHandler

consumes() - Method in class com.hammurapi.eventbus.AbstractEventHandler

consumes() - Method in class com.hammurapi.eventbus.EventHandlerWrapperFilter

consumes() - Method in class com.hammurapi.eventbus.MappingEventHandler

consumes() - Method in class com.hammurapi.eventbus.ReflectiveEventHandler

createCollectorTask(Map<C, Map<<any>, ? super Boolean>>, ExecutorService, AtomicReference<Collection<Future<Collection<EventHandlerWrapper<E, P, C, K, H, S>>>>>, AbstractEventBus.Handle<E, P, C, K>...) - Method in class com.hammurapi.eventbus.PredicatedInferenceNode

createDeputy() - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl

createDeputy() - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl.LocalEventDeputyStore

createExecutorService(ExecutorService, boolean, String) - Method in class com.hammurapi.eventbus.AbstractEventBus

Creates a wrapper around the master executor service for task tracking purposes.

createExecutorService(boolean, String) - Method in class com.hammurapi.eventbus.AbstractEventBus

Create a wrapper around the root executor service for task tracking purposes.

createExecutorService(ExecutorService, boolean, String) - Method in class com.hammurapi.eventbus.local.LocalEventBusBase

createExecutorService(boolean, String) - Method in class com.hammurapi.eventbus.local.LocalEventBusBase

createJoiner(JoinEventHandler<E, P, C, K, H, S>, int[][]) - Method in class com.hammurapi.eventbus.AbstractEventBus

createJoiner(JoinEventHandler<E, P, C, Long, AbstractEventBus.Handle<E, P, C, Long>, S>, int[][]) - Method in class com.hammurapi.eventbus.local.LocalEventBusBase

createLiveView(<any>) - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl

createLiveView(<any>) - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl.LocalEventDeputyStore

createMasterHandle(E, TrackingExecutorService, boolean, <any>[]) - Method in class com.hammurapi.eventbus.AbstractEventBus

createMasterHandle(E, TrackingExecutorService, boolean, <any>[]) - Method in class com.hammurapi.eventbus.local.LocalEventBusBase

To make it visible to LocalDispatchContext.

createPredicatedInferenceNode(PredicatedInferenceNode<E, P, C, K, H, S>, <any>, C) - Method in class com.hammurapi.eventbus.AbstractEventBus

createPredicatedInferenceNode(PredicatedInferenceNode<E, P, C, Long, AbstractEventBus.Handle<E, P, C, Long>, S>, <any>, C) - Method in class com.hammurapi.eventbus.local.LocalEventBusBase

createUnmodifiableFacade() - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl

createUnmodifiableFacade() - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl.LocalEventDeputyStore

createUnmodifiableFacade() - Method in class com.hammurapi.eventbus.local.LocalEventStoreImpl.LocalEventLiveView