spre - Code Search

src/main/java/org/codelibs/core/collection/ArrayIterator.java

/**
 * Adaptor that makes an array into an {@link Iterator}.
 * <p>
 * Usage example:
 * </p>
 *
 * <pre>
 * import static org.codelibs.core.collection.ArrayIterator.*;
 *
 * String[] array = ...;
 * for (String element : iterable(array)) {
 *     ...
 * }
 * </pre>
 *
 * @author shot
 * @param <T> the type of array elements
 */
public class ArrayIterator<T> implements Iterator<T> {

Registered: Fri Sep 05 20:58:11 UTC 2025

- Last Modified: Thu Jun 19 09:12:22 UTC 2025

- 2.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

   * way to obtain a {@code List<ListenableFuture<T>>} from this method is an unchecked (but safe)
   * cast:
   *
   * <pre>
   *   {@code @SuppressWarnings("unchecked") // guaranteed by invokeAll contract}
   *   {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks);}
   * </pre>
   *
   * @return A list of {@code ListenableFuture} instances representing the tasks, in the same

Registered: Fri Sep 05 12:43:10 UTC 2025

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

- 5.5K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/testing/TestLogHandler.java

import org.jspecify.annotations.NullMarked;
import org.jspecify.annotations.Nullable;

/**
 * Tests may use this to intercept messages that are logged by the code under test. Example:
 *
 * <pre>
 *   TestLogHandler handler;
 *
 *   protected void setUp() throws Exception {
 *     super.setUp();
 *     handler = new TestLogHandler();
 *     SomeClass.logger.addHandler(handler);

Registered: Fri Sep 05 12:43:10 UTC 2025

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

- 2.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/resources/plugin/repo3/index.html

	<style>
body {
	background: #fff;
}
	</style>
</head>

<body>
	<header>
		<h1>org/codelibs/fess</h1>
	</header>
	<hr/>
	<main>
		<pre id="contents">
<a href="../">../</a>
<a href="fess/" title="fess/">fess/</a>                                                            -         -

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Mon Jun 17 13:30:41 UTC 2024

- 6.2K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/testing/ClusterException.java

 * presented below:
 *
 * <pre>
 * void runManyThings({@literal List<ThingToRun>} thingsToRun) {
 *   for (ThingToRun thingToRun : thingsToRun) {
 *     thingToRun.run(); // say this may throw an exception, but you want to
 *                       // always run all thingsToRun
 *   }
 * }
 * </pre>
 *
 * <p>This is what the code would become:
 *
 * <pre>

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Sat Dec 21 14:50:24 UTC 2024

- 4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    AtomicInteger totalCalls = new AtomicInteger();
    Runnable intCounter =
        new Runnable() {
          @Override
          public void run() {
            totalCalls.incrementAndGet();
            // Make sure that no other tasks are scheduled to run while this is running.
            assertFalse(fakePool.hasNext());
          }
        };

    assertFalse(fakePool.hasNext());
    e.execute(intCounter);

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 11.4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

LICENSES/vendor/github.com/cespare/xxhash/v2/LICENSE

= vendor/github.com/cespare/xxhash/v2 licensed under: =

Copyright (c) 2016 Caleb Spare

MIT License

Permission is hereby granted, free of charge, to any person obtaining
a copy of this software and associated documentation files (the
"Software"), to deal in the Software without restriction, including
without limitation the rights to use, copy, modify, merge, publish,
distribute, sublicense, and/or sell copies of the Software, and to

Registered: Fri Sep 05 09:05:11 UTC 2025

- Last Modified: Tue May 19 01:37:10 UTC 2020

- 1.2K bytes

- Viewed (0)

github.com/google/guava

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

    private final CountDownLatch delayLatch;

    DelayingIdentityLoader(CountDownLatch delayLatch) {
      this.delayLatch = delayLatch;
    }

    @CanIgnoreReturnValue // Sure, why not?
    @Override
    public T apply(T key) {
      awaitUninterruptibly(delayLatch);
      return key;
    }
  }

  /*

Registered: Fri Sep 05 12:43:10 UTC 2025

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

- 2.8K bytes

- Viewed (0)

github.com/google/guava

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

    }
    if (right == null) {
      return LEFT_IS_GREATER;
    }
    return ordering.compare(left, right);
  }

  @Override
  @SuppressWarnings("nullness") // should be safe, but not sure if we can avoid the warning
  public <S extends @Nullable T> Ordering<S> reverse() {
    // ordering.reverse() might be optimized, so let it do its thing
    return ordering.<T>reverse().<@NonNull S>nullsLast();
  }

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Wed Jun 04 13:03:16 UTC 2025

- 2.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    latch = new CountDownLatch(1);
    future = createListenableFuture(Boolean.TRUE, null, latch);
  }

  @Override
  protected void tearDown() throws Exception {

    // Make sure we have no waiting threads.
    latch.countDown();
  }

  /** Constructs a listenable future with a value available after the latch has counted down. */
  protected abstract <V> ListenableFuture<V> createListenableFuture(

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 6.1K bytes

- Viewed (0)

Search Options