Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 129 for event (0.15 sec)

  1. guava-tests/test/com/google/common/eventbus/EventBusTest.java

        assertEquals("The dead event should wrap the original event.", EVENT, events.get(0).getEvent());
      }
    
      public void testDeadEventPosting() {
        GhostCatcher catcher = new GhostCatcher();
        bus.register(catcher);
    
        bus.post(new DeadEvent(this, EVENT));
    
        List<DeadEvent> 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)
  2. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

        assertEquals("The dead event should wrap the original event.", EVENT, events.get(0).getEvent());
      }
    
      public void testDeadEventPosting() {
        GhostCatcher catcher = new GhostCatcher();
        bus.register(catcher);
    
        bus.post(new DeadEvent(this, EVENT));
    
        List<DeadEvent> events = catcher.getEvents();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

     * specified the JVM flag {@code -XX:+DisableExplicitGC}. But in practice, it works very well for
     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  4. 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)
  5. android/guava/src/com/google/common/base/Suppliers.java

              if (nanos == expirationNanos) { // recheck for lost race
                T t = delegate.get();
                value = t;
                nanos = now + durationNanos;
                // In the very unlikely event that nanos is 0, set it to 1;
                // no one will notice 1 ns of tardiness.
                expirationNanos = (nanos == 0) ? 1 : nanos;
                return t;
              }
            }
          }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/GcFinalization.java

     * specified the JVM flag {@code -XX:+DisableExplicitGC}. But in practice, it works very well for
     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Monitor.java

      //         break;
      //       }
      //     }
      //   }
    
      /**
       * Exactly like guard.isSatisfied(), but in addition signals all waiting threads in the (hopefully
       * unlikely) event that isSatisfied() throws.
       */
      @GuardedBy("lock")
      private boolean isSatisfied(Guard guard) {
        try {
          return guard.isSatisfied();
        } catch (Throwable throwable) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  8. 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)
  9. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Ordering.java

            Platform.tryWeakKeys(new MapMaker()).makeMap();
    
        private Integer getUid(Object obj) {
          Integer uid = uids.get(obj);
          if (uid == null) {
            // One or more integer values could be skipped in the event of a race
            // to generate a UID for the same object from multiple threads, but
            // that shouldn't be a problem.
            uid = counter.getAndIncrement();
            Integer alreadySet = uids.putIfAbsent(obj, uid);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 39.4K bytes
    - Viewed (0)
Back to top