Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 212 for peak (0.1 sec)

  1. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

      fun dispatcherFromMockWebServer() {
        val dispatcher =
          object : okhttp3.mockwebserver.Dispatcher() {
            override fun dispatch(request: RecordedRequest): MockResponse = TODO()
    
            override fun peek(): MockResponse = TODO()
    
            override fun shutdown() = TODO()
          }
      }
    
      @Test
      fun dns() {
        var dns: Dns = Dns { TODO() }
    
        val system: Dns = Dns.SYSTEM
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        monitor.enterWhen(notEmpty);
        try {
          return extract();
        } finally {
          monitor.leave();
        }
      }
    
      @CanIgnoreReturnValue
      @Override
      public @Nullable E peek() {
        final Monitor monitor = this.monitor;
        if (monitor.enterIf(notEmpty)) {
          try {
            return items[takeIndex];
          } finally {
            monitor.leave();
          }
        } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ImmutableRangeSet.java

          while (peekingItr.hasNext()) {
            Range<C> range = peekingItr.next();
            while (peekingItr.hasNext()) {
              Range<C> nextRange = peekingItr.peek();
              if (range.isConnected(nextRange)) {
                checkArgument(
                    range.intersection(nextRange).isEmpty(),
                    "Overlapping ranges not permitted but found %s overlapping %s",
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  4. cmd/metacache-stream_test.go

    		}
    	}
    }
    
    func Test_metacacheReader_peek(t *testing.T) {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	for i, want := range loadMetacacheSampleNames {
    		got, err := r.peek()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			t.Fatal(err)
    		}
    		if got.name != want {
    			t.Errorf("entry %d, want %q, got %q", i, want, got.name)
    		}
    		gotObj, err := r.next()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Tables.java

       *
       * <p>Note: the table assumes complete ownership over of {@code backingMap} and the maps returned
       * by {@code factory}. Those objects should not be manually updated and they should not use soft,
       * weak, or phantom references.
       *
       * @param backingMap place to store the mapping from each row key to its corresponding column key
       *     / value map
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Synchronized.java

        public boolean offer(E e) {
          synchronized (mutex) {
            return delegate().offer(e);
          }
        }
    
        @Override
        @CheckForNull
        public E peek() {
          synchronized (mutex) {
            return delegate().peek();
          }
        }
    
        @Override
        @CheckForNull
        public E poll() {
          synchronized (mutex) {
            return delegate().poll();
          }
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 53.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Synchronized.java

        public boolean offer(E e) {
          synchronized (mutex) {
            return delegate().offer(e);
          }
        }
    
        @Override
        @CheckForNull
        public E peek() {
          synchronized (mutex) {
            return delegate().peek();
          }
        }
    
        @Override
        @CheckForNull
        public E poll() {
          synchronized (mutex) {
            return delegate().poll();
          }
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

            throw afe;
          }
        }
      }
    
      void checkEmpty(BlockingQueue<?> q) {
        try {
          assertTrue(q.isEmpty());
          assertEquals(0, q.size());
          assertNull(q.peek());
          assertNull(q.poll());
          assertNull(q.poll(0, MILLISECONDS));
          assertEquals("[]", q.toString());
          assertTrue(Arrays.equals(q.toArray(), new Object[0]));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ImmutableList.java

          // needed to deal with GWT integer overflow
        }
        return hashCode;
      }
    
      /*
       * Serializes ImmutableLists as their logical contents. This ensures that
       * implementation types do not leak into the serialized representation.
       */
      @J2ktIncompatible // serialization
      static class SerializedForm implements Serializable {
        final Object[] elements;
    
        SerializedForm(Object[] elements) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * the state transitions.
       */
      private static final class ServiceListener extends Service.Listener {
        final Service service;
        // We store the state in a weak reference to ensure that if something went wrong while
        // constructing the ServiceManager we don't pointlessly keep updating the state.
        final WeakReference<ServiceManagerState> state;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top