Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 370 for recovers (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

                return 0;
              }
              break;
            }
          }
    
          // If we're still here, there was a race, so just try again.
        }
      }
    
      /**
       * Removes a number of occurrences of the specified element from this multiset. If the multiset
       * contains fewer than this number of occurrences to begin with, all occurrences will be removed.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      @CanIgnoreReturnValue // pushed down from class to method
      @Override
      public int remainingCapacity() {
        return Integer.MAX_VALUE;
      }
    
      /**
       * Removes a single instance of the specified element from this queue, if it is present. More
       * formally, removes an element {@code e} such that {@code o.equals(e)}, if this queue contains
       * one or more such elements. Returns {@code true} if and only if this queue contained the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 19K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
      fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/EvictingQueue.java

     * cyclic buffer or ring buffer).
     *
     * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a
     * full queue, the queue automatically removes its head element. This is different from conventional
     * bounded queues, which either block or reject new elements when full.
     *
     * <p>This class is not thread-safe, and does not accept null elements.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Table.java

       * its cell view, as returned by {@link #cellSet}.
       */
      @Override
      int hashCode();
    
      // Mutators
    
      /** Removes all mappings from the table. */
      void clear();
    
      /**
       * Associates the specified value with the specified keys. If the table already contained a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
      fun <T : CallEvent> removeUpToEvent(eventClass: Class<T>): T {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/graph/PackageSanityTests.java

    import static com.google.common.truth.Truth.assertWithMessage;
    
    import com.google.common.testing.AbstractPackageSanityTests;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Covers basic sanity checks for the entire package.
     *
     * @author Kurt Alfred Kluever
     */
    
    @NullUnmarked
    public class PackageSanityTests extends AbstractPackageSanityTests {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 28 01:26:26 GMT 2024
    - 3.2K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/Multimap.java

       *     multimap already contained the key-value pair and doesn't allow duplicates
       */
      @CanIgnoreReturnValue
      boolean put(@ParametricNullness K key, @ParametricNullness V value);
    
      /**
       * Removes a single key-value pair with the key {@code key} and the value {@code value} from this
       * multimap, if such exists. If multiple key-value pairs in the multimap fit this description,
       * which one is removed is unspecified.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 15.7K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        manager.stopAsync();
        assertThrows(TimeoutException.class, () -> manager.awaitStopped(1, MILLISECONDS));
        manager.awaitStopped(5, SECONDS); // no exception thrown
      }
    
      /**
       * This covers a case where if the last service to stop failed then the stopped callback would
       * never be called.
       */
      public void testSingleFailedServiceCallsStopped() {
        Service a = new FailStartService();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/platform/Platform.kt

     *
     * Supported on OpenJDK 9+ via SSLParameters and SSLSocket features.
     *
     * ### Trust Manager Extraction
     *
     * Supported on Android 2.3+ and OpenJDK 7+. There are no public APIs to recover the trust
     * manager that was used to create an [SSLSocketFactory].
     *
     * Not supported by choice on JDK9+ due to access checks.
     *
     * ### Android Cleartext Permit Detection
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 8.1K bytes
    - Click Count (0)
Back to Top