- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for registered (0.58 sec)
-
android/guava/src/com/google/common/eventbus/Subscriber.java
* events to it. * * <p>Two subscribers are equivalent when they refer to the same method on the same object (not * class). This property is used to ensure that no subscriber method is registered more than once. * * @author Colin Decker */ @ElementTypesAreNonnullByDefault class Subscriber { /** Creates a {@code Subscriber} for {@code method} on {@code listener}. */
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) -
guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java
assertEquals(0, registry.getSubscribersForTesting(String.class).size()); registry.register(new StringSubscriber()); assertEquals(1, registry.getSubscribersForTesting(String.class).size()); registry.register(new StringSubscriber()); assertEquals(2, registry.getSubscribersForTesting(String.class).size()); registry.register(new ObjectSubscriber()); assertEquals(2, registry.getSubscribersForTesting(String.class).size());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
import java.util.Queue; import java.util.concurrent.Executor; import java.util.logging.Level; /** * A list of listeners for implementing a concurrency friendly observable object. * * <p>Listeners are registered once via {@link #addListener} and then may be invoked by {@linkplain * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. *
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) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
*/ @DoNotMock("Use the methods in Futures (like immediateFuture) or SettableFuture") @ElementTypesAreNonnullByDefault public interface ListenableFuture<V extends @Nullable Object> extends Future<V> { /** * Registers a listener to be {@linkplain Executor#execute(Runnable) run} on the given executor. * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java
assertEquals(0, registry.getSubscribersForTesting(String.class).size()); registry.register(new StringSubscriber()); assertEquals(1, registry.getSubscribersForTesting(String.class).size()); registry.register(new StringSubscriber()); assertEquals(2, registry.getSubscribersForTesting(String.class).size()); registry.register(new ObjectSubscriber()); assertEquals(2, registry.getSubscribersForTesting(String.class).size());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSink.java
*/ public void write(byte[] bytes) throws IOException { checkNotNull(bytes); Closer closer = Closer.create(); try { OutputStream out = closer.register(openStream()); out.write(bytes); out.flush(); // https://code.google.com/p/guava-libraries/issues/detail?id=1330 } catch (Throwable e) { throw closer.rethrow(e); } finally {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 5.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/TearDownAccepter.java
* * @author Kevin Bourrillion * @since 10.0 */ @DoNotMock("Implement with a lambda") @GwtCompatible @ElementTypesAreNonnullByDefault public interface TearDownAccepter { /** * Registers a TearDown implementor which will be run after the test proper. * * <p>In JUnit4 language, that means as an {@code @After}. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 12 19:22:18 GMT 2023 - 1.3K 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 May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
*/ @DoNotMock("Use the methods in Futures (like immediateFuture) or SettableFuture") @ElementTypesAreNonnullByDefault public interface ListenableFuture<V extends @Nullable Object> extends Future<V> { /** * Registers a listener to be {@linkplain Executor#execute(Runnable) run} on the given executor. * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TearDownAccepter.java
* * @author Kevin Bourrillion * @since 10.0 */ @DoNotMock("Implement with a lambda") @GwtCompatible @ElementTypesAreNonnullByDefault public interface TearDownAccepter { /** * Registers a TearDown implementor which will be run after the test proper. * * <p>In JUnit4 language, that means as an {@code @After}. *
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 12 19:22:18 GMT 2023 - 1.3K bytes - Viewed (0)