Lines Matching defs:executor
24 import java.util.concurrent.Executor;
27 * An {@link EventBus} that takes the Executor of your choice and uses it to
35 private final Executor executor;
42 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
46 * @param executor Executor to use to dispatch events. It is the caller's
47 * responsibility to shut down the executor after the last event has
50 public AsyncEventBus(String identifier, Executor executor) {
52 this.executor = checkNotNull(executor);
56 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
59 * @param executor Executor to use to dispatch events. It is the caller's
60 * responsibility to shut down the executor after the last event has
66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
68 this.executor = checkNotNull(executor);
72 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
75 * @param executor Executor to use to dispatch events. It is the caller's
76 * responsibility to shut down the executor after the last event has
79 public AsyncEventBus(Executor executor) {
81 this.executor = checkNotNull(executor);
107 * Calls the {@link #executor} to dispatch {@code event} to {@code subscriber}.
113 executor.execute(
