Seconds - Code Search

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

                        barrier.await(1, SECONDS);

                        // WAIT #2
                        barrier.await(1, SECONDS);
                        assertTrue(executor.isShutdown());
                        assertFalse(executor.isTerminated());

                        // WAIT #3
                        barrier.await(1, SECONDS);
                        return null;
                      });

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

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 26.1K bytes

- Click Count (0)

github.com/google/guava

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

    assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS))
        .isEqualTo("foo");
  }

  public void testGetCheckedTimed_interrupted() {
    SettableFuture<String> future = SettableFuture.create();
    Thread.currentThread().interrupt();
    try {
      getChecked(future, TwoArgConstructorException.class, 0, SECONDS);
      fail();
    } catch (TwoArgConstructorException expected) {

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

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 16.5K bytes

- Click Count (0)

github.com/google/guava

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

    assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS))
        .isEqualTo("foo");
  }

  public void testGetCheckedTimed_interrupted() {
    SettableFuture<String> future = SettableFuture.create();
    Thread.currentThread().interrupt();
    try {
      getChecked(future, TwoArgConstructorException.class, 0, SECONDS);
      fail();
    } catch (TwoArgConstructorException expected) {

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

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 16.5K bytes

- Click Count (0)

github.com/google/guava

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

                        barrier.await(1, SECONDS);

                        // WAIT #2
                        barrier.await(1, SECONDS);
                        assertTrue(executor.isShutdown());
                        assertFalse(executor.isTerminated());

                        // WAIT #3
                        barrier.await(1, SECONDS);
                        return null;
                      });

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

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 26.1K bytes

- Click Count (0)

github.com/google/guava

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

    assertTrue(limiter.tryAcquire(0, SECONDS));
    assertFalse(limiter.tryAcquire(0, SECONDS));
    assertFalse(limiter.tryAcquire(0, SECONDS));
    stopwatch.sleepMillis(100);
    assertFalse(limiter.tryAcquire(0, SECONDS));
  }

  public void testTryAcquire_someWaitAllowed() {
    RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
    assertTrue(limiter.tryAcquire(0, SECONDS));

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

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 22K bytes

- Click Count (0)

github.com/google/guava

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

    assertTrue(limiter.tryAcquire(0, SECONDS));
    assertFalse(limiter.tryAcquire(0, SECONDS));
    assertFalse(limiter.tryAcquire(0, SECONDS));
    stopwatch.sleepMillis(100);
    assertFalse(limiter.tryAcquire(0, SECONDS));
  }

  public void testTryAcquire_someWaitAllowed() {
    RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
    assertTrue(limiter.tryAcquire(0, SECONDS));

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

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 22K bytes

- Click Count (0)

github.com/google/guava

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

    runLatch.await();
    taskLatch.countDown();

    ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    assertThat(e).hasCauseThat().isInstanceOf(IllegalStateException.class);

    assertTrue(listenerLatch.await(5, SECONDS));
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
  }

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

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/square/okhttp

okcurl/src/main/kotlin/okhttp3/curl/Main.kt

  ).help(
    "Maximum time allowed for connection (seconds)",
  ).int()
    .default(DEFAULT_TIMEOUT)

  val readTimeout: Int by option("--read-timeout")
    .help("Maximum time allowed for reading data (seconds)")
    .int()
    .default(DEFAULT_TIMEOUT)

  val callTimeout: Int by option(
    "--call-timeout",
  ).help(
    "Maximum time allowed for the entire call (seconds)",
  ).int()
    .default(DEFAULT_TIMEOUT)

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 6K bytes

- Click Count (0)

github.com/google/guava

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

    runLatch.await();
    taskLatch.countDown();

    ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    assertThat(e).hasCauseThat().isInstanceOf(IllegalStateException.class);

    assertTrue(listenerLatch.await(5, SECONDS));
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
  }

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

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/CacheControlTest.kt

  @Test
  @Throws(Exception::class)
  fun completeBuilder() {
    val cacheControl =
      CacheControl
        .Builder()
        .noCache()
        .noStore()
        .maxAge(1.seconds)
        .maxStale(2.seconds)
        .minFresh(3.seconds)
        .onlyIfCached()
        .noTransform()
        .immutable()
        .build()
    assertThat(cacheControl.toString()).isEqualTo(

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 2.7K bytes

- Click Count (0)

Search Options