Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for RemovalNotification (3.06 sec)

  1. guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java

      }
    
      public void testComputeIfPresentRemove() {
        List<RemovalNotification<Integer, Integer>> notifications = new ArrayList<>();
        Cache<Integer, Integer> cache =
            CacheBuilder.newBuilder()
                .removalListener(
                    new RemovalListener<Integer, Integer>() {
                      @Override
                      public void onRemoval(RemovalNotification<Integer, Integer> notification) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/cache/TestingRemovalListeners.java

      }
    
      /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */
      @GwtIncompatible // ConcurrentLinkedQueue
      static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>>
          implements RemovalListener<K, V> {
    
        @Override
        public void onRemoval(RemovalNotification<K, V> notification) {
          add(notification);
        }
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/cache/TestingRemovalListeners.java

      }
    
      /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */
      @GwtIncompatible // ConcurrentLinkedQueue
      static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>>
          implements RemovalListener<K, V> {
    
        @Override
        public void onRemoval(RemovalNotification<K, V> notification) {
          add(notification);
        }
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/NullCacheTest.java

                .removalListener(listener)
                .build(constantLoader(computed));
    
        Object key = new Object();
        assertThat(cache.getUnchecked(key)).isSameInstanceAs(computed);
        RemovalNotification<Object, Object> notification = listener.remove();
        assertThat(notification.getKey()).isSameInstanceAs(key);
        assertThat(notification.getValue()).isSameInstanceAs(computed);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/NullCacheTest.java

                .removalListener(listener)
                .build(constantLoader(computed));
    
        Object key = new Object();
        assertThat(cache.getUnchecked(key)).isSameInstanceAs(computed);
        RemovalNotification<Object, Object> notification = listener.remove();
        assertThat(notification.getKey()).isSameInstanceAs(key);
        assertThat(notification.getValue()).isSameInstanceAs(computed);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        // contain the computed value (b -> b), since the clear() happened before the computation
        // completed.
        assertThat(listener).hasSize(1);
        RemovalNotification<String, String> notification = listener.remove();
        assertThat(notification.getKey()).isEqualTo("a");
        assertThat(notification.getValue()).isEqualTo("a");
        assertThat(cache.size()).isEqualTo(1);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/LocalCacheTest.java

      }
    
      public void testComputeIfAbsent_removalListener() {
        List<RemovalNotification<Object, Object>> notifications = new ArrayList<>();
        RemovalListener<Object, Object> removalListener =
            new RemovalListener<Object, Object>() {
              @Override
              public void onRemoval(RemovalNotification<Object, Object> notification) {
                notifications.add(notification);
              }
            };
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 117.5K bytes
    - Viewed (0)
  8. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

      private long currentTimeNanos() {
        return ticker.read();
      }
    
      private void alertListenerIfPresent(K key, V value, RemovalCause cause) {
        if (removalListener != null) {
          removalListener.onRemoval(RemovalNotification.create(key, value, cause));
        }
      }
    
      @SuppressWarnings("GoodTime") // timestamps as numeric primitives
      private V load(K key) throws ExecutionException {
        long startTime = ticker.read();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        RuntimeException e = new RuntimeException();
        RemovalListener<Object, Object> listener =
            new RemovalListener<Object, Object>() {
              @Override
              public void onRemoval(RemovalNotification<Object, Object> notification) {
                throw e;
              }
            };
    
        CacheBuilder<Object, Object> builder = createCacheBuilder().removalListener(listener);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 115.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/cache/CacheBuilderGwtTest.java

        int[] stats = new int[4];
    
        RemovalListener<Integer, Integer> countingListener =
            new RemovalListener<Integer, Integer>() {
              @Override
              public void onRemoval(RemovalNotification<Integer, Integer> notification) {
                switch (notification.getCause()) {
                  case EXPIRED:
                    stats[0]++;
                    break;
                  case EXPLICIT:
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 14.8K bytes
    - Viewed (0)
Back to top