Lines Matching defs:bus
39 private static final String BUS_IDENTIFIER = "test-bus";
41 private EventBus bus;
45 bus = new EventBus(BUS_IDENTIFIER);
50 bus.register(catcher);
51 bus.post(EVENT);
86 bus.register(stringCatcher);
87 bus.register(objCatcher);
88 bus.register(compCatcher);
94 bus.post(EVENT);
95 bus.post(OBJ_EVENT);
96 bus.post(COMP_EVENT);
177 bus.register(catcher);
180 bus.post(EVENT);
190 bus.register(catcher);
192 bus.post(new DeadEvent(this, EVENT));
203 Set<Class<?>> hierarchy = bus.flattenHierarchy(fixture.getClass());
214 bus.register(new Object());
221 bus.unregister(catcher1);
227 bus.register(catcher1);
228 bus.post(EVENT);
229 bus.register(catcher2);
230 bus.post(EVENT);
242 bus.unregister(catcher1);
243 bus.post(EVENT);
251 bus.unregister(catcher1);
257 bus.unregister(catcher2);
258 bus.post(EVENT);
274 futures.add(executor.submit(new Registrator(bus, catchers)));
281 bus.post(EVENT);
298 bus.register(new Callback<String>() {
306 bus.post("hello");
334 * Runnable which registers a StringCatcher on an event bus and adds it to a
338 private final EventBus bus;
341 Registrator(EventBus bus, List<StringCatcher> catchers) {
342 this.bus = bus;
349 bus.register(catcher);
