Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 159 for Seek (0.06 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt

        // other threads waiting on take() will also return.
        if (result == DEAD_LETTER) responseQueue.add(DEAD_LETTER)
    
        return result
      }
    
      override fun peek(): MockResponse {
        return responseQueue.peek() ?: failFastResponse ?: super.peek()
      }
    
      open fun enqueueResponse(response: MockResponse) {
        responseQueue.add(response)
      }
    
      open fun clear() {
        responseQueue.clear()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

        public boolean remove(Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove(object);
        }
    
        @Override
        public @Nullable E peek() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.peek();
        }
    
        @Override
        public E element() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.element();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ForwardingQueue.java

      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public E remove() {
        return delegate().remove();
      }
    
      @Override
      @CheckForNull
      public E peek() {
        return delegate().peek();
      }
    
      @Override
      @ParametricNullness
      public E element() {
        return delegate().element();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 29 19:42:21 UTC 2021
    - 4.1K bytes
    - Viewed (0)
  4. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

        override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse {
          return delegate.dispatch(request.unwrap()).wrap()
        }
    
        override fun peek(): mockwebserver3.MockResponse {
          return delegate.peek().wrap()
        }
    
        override fun shutdown() {
          delegate.shutdown()
        }
      }
    }
    
    internal fun MockResponse.wrap(): mockwebserver3.MockResponse {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        public boolean remove(Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove(object);
        }
    
        @Override
        public @Nullable E peek() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.peek();
        }
    
        @Override
        public E element() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.element();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/lex/tokenizer.go

    	switch t.tok {
    	case '\n':
    		t.line++
    	case '-':
    		if s.Peek() == '>' {
    			s.Next()
    			t.tok = ARR
    			return ARR
    		}
    	case '@':
    		if s.Peek() == '>' {
    			s.Next()
    			t.tok = ROT
    			return ROT
    		}
    	case '<':
    		if s.Peek() == '<' {
    			s.Next()
    			t.tok = LSH
    			return LSH
    		}
    	case '>':
    		if s.Peek() == '>' {
    			s.Next()
    			t.tok = RSH
    			return RSH
    		}
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Aug 04 20:35:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        assertEquals(3, (int) mmHeap.pollLast());
        assertEquals(1, (int) mmHeap.peek());
        assertEquals(2, (int) mmHeap.peekLast());
        assertEquals(2, (int) mmHeap.pollLast());
        assertEquals(1, (int) mmHeap.peek());
        assertEquals(1, (int) mmHeap.peekLast());
        assertEquals(1, (int) mmHeap.pollLast());
        assertNull(mmHeap.peek());
        assertNull(mmHeap.peekLast());
        assertNull(mmHeap.pollLast());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  8. cmd/update-notifier_test.go

    		{25 * time.Hour, "my_download_url", "1 day before the latest release"},
    		{49 * time.Hour, "my_download_url", "2 days before the latest release"},
    		{7 * 24 * time.Hour, "my_download_url", "1 week before the latest release"},
    		{8 * 24 * time.Hour, "my_download_url", "1 week before the latest release"},
    		{15 * 24 * time.Hour, "my_download_url", "2 weeks before the latest release"},
    
    		// Testcase index 20
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 31 15:36:19 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/AbstractIterator.java

       * contract of {@link PeekingIterator#peek()}.
       *
       * <p>Implementations of {@code AbstractIterator} that wish to expose this functionality should
       * implement {@code PeekingIterator}.
       */
      @ParametricNullness
      public final T peek() {
        if (!hasNext()) {
          throw new NoSuchElementException();
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Mar 18 02:04:10 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

        public boolean remove(Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove(object);
        }
    
        @Override
        public @Nullable E peek() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.peek();
        }
    
        @Override
        public E element() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.element();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top