- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for bus (0.14 sec)
-
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
Method concat = String.class.getMethod("concat", String.class); new EqualsTester() .addEqualityGroup( Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) .addEqualityGroup(Subscriber.create(bus, "foo", concat)) .testEquals(); } private Method getTestSubscriberMethod(String name) { try {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
private static final String BUS_IDENTIFIER = "test-bus"; private EventBus bus; @Override protected void setUp() throws Exception { super.setUp(); bus = new EventBus(BUS_IDENTIFIER); } public void testBasicCatcherDistribution() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); bus.post(EVENT); List<String> events = catcher.getEvents();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
private static final String BUS_IDENTIFIER = "test-bus"; private EventBus bus; @Override protected void setUp() throws Exception { super.setUp(); bus = new EventBus(BUS_IDENTIFIER); } public void testBasicCatcherDistribution() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); bus.post(EVENT); List<String> events = catcher.getEvents();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
subscriber(bus, i3, "handleInteger", Integer.class)); private final StringSubscriber s1 = new StringSubscriber("s1"); private final StringSubscriber s2 = new StringSubscriber("s2"); private final ImmutableList<Subscriber> stringSubscribers = ImmutableList.of( subscriber(bus, s1, "handleString", String.class), subscriber(bus, s2, "handleString", String.class));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 27 15:41:25 GMT 2022 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
* identifier} as the bus's name for logging purposes. * * @param identifier short name for the bus, for logging purposes. * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut * down the executor after the last event has been posted to this event bus. */ public AsyncEventBus(String identifier, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 2.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java
public class ReentrantEventsTest extends TestCase { static final String FIRST = "one"; static final Double SECOND = 2.0d; final EventBus bus = new EventBus(); public void testNoReentrantEvents() { ReentrantEventsHater hater = new ReentrantEventsHater(); bus.register(hater); bus.post(FIRST); assertEquals( "ReentrantEventHater expected 2 events", Lists.<Object>newArrayList(FIRST, SECOND),
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
H getSubscriber() { return subscriber; } @Override protected void setUp() throws Exception { subscriber = createSubscriber(); EventBus bus = new EventBus(); bus.register(subscriber); bus.post(EVENT); } @Override protected void tearDown() throws Exception { subscriber = null; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
private FakeExecutor executor; private AsyncEventBus bus; @Override protected void setUp() throws Exception { super.setUp(); executor = new FakeExecutor(); bus = new AsyncEventBus(executor); } public void testBasicDistribution() { StringCatcher catcher = new StringCatcher(); bus.register(catcher);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
H getSubscriber() { return subscriber; } @Override protected void setUp() throws Exception { subscriber = createSubscriber(); EventBus bus = new EventBus(); bus.register(subscriber); bus.post(EVENT); } @Override protected void tearDown() throws Exception { subscriber = null; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Subscriber.java
static Subscriber create(EventBus bus, Object listener, Method method) { return isDeclaredThreadSafe(method) ? new Subscriber(bus, listener, method) : new SynchronizedSubscriber(bus, listener, method); } /** The event bus this subscriber belongs to. */ @Weak private EventBus bus; /** The object with the subscriber method. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 4.7K bytes - Viewed (0)