- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 84 for Gevent (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
private static final ListenerCallQueue.Event<Listener> HEALTHY_EVENT = new ListenerCallQueue.Event<Listener>() { @Override public void call(Listener listener) { listener.healthy(); } @Override public String toString() { return "healthy()"; } }; private static final ListenerCallQueue.Event<Listener> STOPPED_EVENT =
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/StringCatcher.java
public class StringCatcher { private List<String> events = Lists.newArrayList(); @Subscribe public void hereHaveAString(@Nullable String string) { events.add(string); } public void methodWithoutAnnotation(@Nullable String string) { Assert.fail("Event bus must not call methods without @Subscribe!"); } public List<String> getEvents() { return events; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed May 16 22:49:59 GMT 2018 - 1.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/NeitherAbstractNorAnnotatedInSuperclassTest.java
assertThat(getSubscriber().overriddenInSubclassNowhereAnnotatedEvents).isEmpty(); } public void testOverriddenAndAnnotatedInSubclass() { assertThat(getSubscriber().overriddenAndAnnotatedInSubclassEvents).contains(EVENT); } @Override SubClass createSubscriber() { return new SubClass(); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/NeitherAbstractNorAnnotatedInSuperclassTest.java
assertThat(getSubscriber().overriddenInSubclassNowhereAnnotatedEvents).isEmpty(); } public void testOverriddenAndAnnotatedInSubclass() { assertThat(getSubscriber().overriddenAndAnnotatedInSubclassEvents).contains(EVENT); } @Override SubClass createSubscriber() { return new SubClass(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/BiMap.java
// Modification Operations /** * {@inheritDoc} * * @throws IllegalArgumentException if the given value is already bound to a different key in this * bimap. The bimap will remain unmodified in this event. To avoid this exception, call {@link * #forcePut} instead. */ @CanIgnoreReturnValue @Override @CheckForNull V put(@ParametricNullness K key, @ParametricNullness V value); /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Jun 17 14:40:53 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMultiset.java
* modifications, or we'll modify the already-built ImmutableMultiset. */ boolean buildInvoked = false; /** * In the event of a setCount(elem, 0) call, we may need to remove elements, which destroys the * insertion order property of ObjectCountHashMap. In that event, we need to convert to a * ObjectCountLinkedHashMap, but we need to know we did that so we can convert back. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
/** How long after the last write an entry becomes a candidate for refresh. */ final long refreshNanos; /** Entries waiting to be consumed by the removal listener. */ // TODO(fry): define a new type which creates event objects and automates the clear logic final Queue<RemovalNotification<K, V>> removalNotificationQueue; /** * A listener that is invoked when an entry is removed due to expiration or garbage collection of
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
checkNotNull(event); checkNotNull(subscribers); // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) { dispatching.set(true); try { Event nextEvent;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Enqueues an event to be run on currently known listeners. * * <p>The {@code toString} method of the Event itself will be used to describe the event in the * case of an error. * * @param event the callback to execute on {@link #dispatch} */ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
// We post the event, but our Executor will not deliver it until instructed. bus.post(EVENT); List<String> events = catcher.getEvents(); assertTrue("No events should be delivered synchronously.", events.isEmpty()); // Now we find the task in our Executor and explicitly activate it. List<Runnable> tasks = executor.getTasks(); assertEquals("One event dispatch task should be queued.", 1, tasks.size());
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)