peak - Code Search

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

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jul 16 17:42:14 GMT 2025

- 7.4K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/MapMaker.java

import java.util.concurrent.ConcurrentMap;
import org.jspecify.annotations.Nullable;

/**
 * A builder of {@link ConcurrentMap} instances that can have keys or values automatically wrapped
 * in {@linkplain WeakReference weak} references.
 *
 * <p>Usage example:
 *
 * {@snippet :
 * ConcurrentMap<Request, Stopwatch> timers = new MapMaker()
 *     .concurrencyLevel(4)
 *     .weakKeys()
 *     .makeMap();
 * }
 *

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 12.8K bytes

- Click Count (0)

github.com/golang/go

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
		}
	}

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Thu Aug 04 20:35:21 GMT 2022

- 3K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/Interners.java

      this.strong = true;
      return this;
    }

    /**
     * Instructs the {@link InternerBuilder} to build a weak interner.
     *
     * @see Interners#newWeakInterner()
     */
    @CanIgnoreReturnValue
    @GwtIncompatible // java.lang.ref.WeakReference
    public InternerBuilder weak() {
      this.strong = false;
      return this;
    }

    /**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Mar 08 16:16:42 GMT 2026

- 6K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/ForwardingQueue.java

    return delegate().poll();
  }

  @CanIgnoreReturnValue
  @Override
  @ParametricNullness
  public E remove() {
    return delegate().remove();
  }

  @Override
  public @Nullable E peek() {
    return delegate().peek();
  }

  @Override
  @ParametricNullness
  public E element() {
    return delegate().element();
  }

  /**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 3.9K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/InternersTest.java

  }

  public void testWeak_builder() {
    int concurrencyLevel = 42;
    Interner<Object> interner =
        Interners.newBuilder().weak().concurrencyLevel(concurrencyLevel).build();
    InternerImpl<Object> internerImpl = (InternerImpl<Object>) interner;
    assertEquals(Strength.WEAK, internerImpl.map.keyStrength());
    assertEquals(concurrencyLevel, internerImpl.map.concurrencyLevel);
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Mar 13 13:01:07 GMT 2026

- 4.5K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponseTest.java

        SrvPipePeekResponse peek = resp.getOutputData(SrvPipePeekResponse.class);
        assertNotNull(peek);
        assertEquals(16, resp.getOutputLength());
        // Default zeros
        assertEquals(0, peek.getNamedPipeState());
        assertEquals(0, peek.getReadDataAvailable());
        assertEquals(0, peek.getNumberOfMessages());
        assertEquals(0, peek.getMessageLength());
    }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 10.9K bytes

- Click Count (0)

github.com/google/guava

android/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();
    }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 17 20:26:29 GMT 2025

- 6.3K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/SortedMultisets.java

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.collect.Multiset.Entry;
import com.google.j2objc.annotations.Weak;
import java.util.Comparator;
import java.util.Iterator;
import java.util.NavigableSet;
import java.util.NoSuchElementException;
import java.util.SortedSet;
import org.jspecify.annotations.Nullable;

/**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 5.5K bytes

- Click Count (0)

github.com/google/guava

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

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jul 16 17:42:14 GMT 2025

- 4.8K bytes

- Click Count (0)

Search Options