Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for peekc (0.07 seconds)

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

  2. github.com/google/guava

    android/guava-tests/test/com/google/common/cache/LocalCacheTest.java 

        segment.count = 1;
    segment.totalWeight = 1;

    assertThat(table.get(0)).isSameInstanceAs(entry);
    assertThat(segment.accessQueue.peek()).isSameInstanceAs(entry);
    assertThat(segment.writeQueue.peek()).isSameInstanceAs(entry);

    segment.clear();
    assertThat(table.get(0)).isNull();
    assertThat(segment.accessQueue.isEmpty()).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  3. github.com/google/guava

    guava-tests/test/com/google/common/cache/LocalCacheTest.java 

        segment.count = 1;
    segment.totalWeight = 1;

    assertThat(table.get(0)).isSameInstanceAs(entry);
    assertThat(segment.accessQueue.peek()).isSameInstanceAs(entry);
    assertThat(segment.writeQueue.peek()).isSameInstanceAs(entry);

    segment.clear();
    assertThat(table.get(0)).isNull();
    assertThat(segment.accessQueue.isEmpty()).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  4. github.com/google/guava

    android/guava/src/com/google/common/cache/LocalCache.java 

          drainRecencyQueue();

      ReferenceEntry<K, V> e;
      while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
          throw new AssertionError();
        }
      }
      while ((e = accessQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  5. github.com/google/guava

    guava/src/com/google/common/cache/LocalCache.java 

          drainRecencyQueue();

      ReferenceEntry<K, V> e;
      while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
          throw new AssertionError();
        }
      }
      while ((e = accessQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  6. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt 

        val requestFinished = CountDownLatch(2)
    val dispatcher: QueueDispatcher =
      object : QueueDispatcher() {
        override fun dispatch(request: RecordedRequest): MockResponse {
          if (peek().onResponseStart is CloseSocket) {
            requestFinished.await()
          }
          return super.dispatch(request)
        }
      }
    dispatcher.enqueue(MockResponse(body = "seed connection pool"))
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
Back to Top