Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for remainingCapacity (0.27 seconds)

  1. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      /** Constructor for use by subclasses. */
      protected ForwardingBlockingDeque() {}
    
      @Override
      protected abstract BlockingDeque<E> delegate();
    
      @Override
      public int remainingCapacity() {
        return delegate().remainingCapacity();
      }
    
      @Override
      public void putFirst(E e) throws InterruptedException {
        delegate().putFirst(e);
      }
    
      @Override
      public void putLast(E e) throws InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      /** Constructor for use by subclasses. */
      protected ForwardingBlockingDeque() {}
    
      @Override
      protected abstract BlockingDeque<E> delegate();
    
      @Override
      public int remainingCapacity() {
        return delegate().remainingCapacity();
      }
    
      @Override
      public void putFirst(E e) throws InterruptedException {
        delegate().putFirst(e);
      }
    
      @Override
      public void putLast(E e) throws InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

        return delegate().poll(timeout, unit);
      }
    
      @Override
      public void put(E e) throws InterruptedException {
        delegate().put(e);
      }
    
      @Override
      public int remainingCapacity() {
        return delegate().remainingCapacity();
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public E take() throws InterruptedException {
        return delegate().take();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

      /** Constructor for use by subclasses. */
      protected ForwardingBlockingDeque() {}
    
      @Override
      protected abstract BlockingDeque<E> delegate();
    
      @Override
      public int remainingCapacity() {
        return delegate().remainingCapacity();
      }
    
      @Override
      public void putFirst(E e) throws InterruptedException {
        delegate().putFirst(e);
      }
    
      @Override
      public void putLast(E e) throws InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/EvictingQueue.java

      }
    
      /**
       * Returns the number of additional elements that this queue can accept without evicting; zero if
       * the queue is currently full.
       *
       * @since 16.0
       */
      public int remainingCapacity() {
        return maxSize - size();
      }
    
      @Override
      protected Queue<E> delegate() {
        return delegate;
      }
    
      /**
    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)
  6. android/guava/src/com/google/common/collect/EvictingQueue.java

      }
    
      /**
       * Returns the number of additional elements that this queue can accept without evicting; zero if
       * the queue is currently full.
       *
       * @since 16.0
       */
      public int remainingCapacity() {
        return maxSize - size();
      }
    
      @Override
      protected Queue<E> delegate() {
        return delegate;
      }
    
      /**
    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)
  7. guava-tests/test/com/google/common/collect/EvictingQueueTest.java

        assertEquals(3, queue.remainingCapacity());
        queue.add("hi");
        assertEquals(2, queue.remainingCapacity());
        queue.add("hi");
        assertEquals(1, queue.remainingCapacity());
        queue.add("hi");
        assertEquals(0, queue.remainingCapacity());
      }
    
      public void testEvictingAfterOne() throws Exception {
        EvictingQueue<String> queue = EvictingQueue.create(1);
        assertEquals(0, queue.size());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.9K bytes
    - Click Count (0)
Back to Top