startTag - Code Search

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

      }
    }

    @Override
    public synchronized void starting() {
      assertTrue(stateHistory.isEmpty());
      assertThat(service.state()).isNotEqualTo(State.NEW);
      stateHistory.add(State.STARTING);
    }

    @Override
    public synchronized void running() {
      assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory));
      stateHistory.add(State.RUNNING);

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

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

- 28.7K bytes

- Click Count (0)

github.com/google/guava

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

      }
    }

    @Override
    public synchronized void starting() {
      assertTrue(stateHistory.isEmpty());
      assertThat(service.state()).isNotEqualTo(State.NEW);
      stateHistory.add(State.STARTING);
    }

    @Override
    public synchronized void running() {
      assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory));
      stateHistory.add(State.RUNNING);

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

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

- 28.7K bytes

- Click Count (0)

github.com/google/guava

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

    service.startAsync().awaitRunning();
    assertEquals(1, service.startUpCalled);
    assertEquals(Service.State.RUNNING, service.state());
    assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
  }

  public void testStart_failed() {
    Exception exception = new Exception("deliberate");
    TestService service =
        new TestService() {
          @Override

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

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

- 7.7K bytes

- Click Count (0)

github.com/google/guava

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

    service.startAsync().awaitRunning();
    assertEquals(1, service.startUpCalled);
    assertEquals(Service.State.RUNNING, service.state());
    assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
  }

  public void testStart_failed() {
    Exception exception = new Exception("deliberate");
    TestService service =
        new TestService() {
          @Override

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

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

- 7.7K bytes

- Click Count (0)

github.com/gradle/gradle

.teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt

                    }
            }
    }
}

fun ProjectFeatures.buildReportTab(
    title: String,
    startPage: String,
) {
    feature {
        type = "ReportTab"
        param("startPage", startPage)
        param("title", title)
        param("type", "BuildReportTab")
    }
}

fun BaseGradleBuildType.gradleRunnerStep(
    model: CIBuildModel,

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Fri Mar 13 05:03:56 GMT 2026

- 8.5K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java

            }

            if (logger.isDebugEnabled()) {
                logger.debug("Starting job: id={}, scriptType={}, script={}", id, scriptType, script);
            } else if (scheduledJob.isLoggingEnabled() && logger.isInfoEnabled()) {
                logger.info("Starting job: id={}", id);
            }

            final Object ret = jobExecutor.execute(Constants.DEFAULT_SCRIPT, script);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Sat Mar 28 11:55:54 GMT 2026

- 5.7K bytes

- Click Count (0)

github.com/google/guava

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

    @Override
    protected void startUp() {
      assertFalse(startUpCalled);
      assertFalse(runCalled);
      assertFalse(shutDownCalled);
      startUpCalled = true;
      assertEquals(State.STARTING, state());
    }

    @Override
    protected void run() {
      assertTrue(startUpCalled);
      assertFalse(runCalled);
      assertFalse(shutDownCalled);
      runCalled = true;

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

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

- 12.8K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/ByteSourceTester.java

      suite.addTest(suiteForBytes(sliced, bytes, name + ".slice[long, long]", desc, false));

      // test a slice() of the ByteSource starting at a random offset with a length of
      // Long.MAX_VALUE
      ByteSourceFactory slicedLongMaxValue =
          SourceSinkFactories.asSlicedByteSourceFactory(factory, off, Long.MAX_VALUE);
      suite.addTest(

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

- Last Modified: Thu Mar 19 18:53:45 GMT 2026

- 8.6K bytes

- Click Count (0)

github.com/google/guava

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

    @Override
    protected void startUp() {
      assertFalse(startUpCalled);
      assertFalse(runCalled);
      assertFalse(shutDownCalled);
      startUpCalled = true;
      assertEquals(State.STARTING, state());
    }

    @Override
    protected void run() {
      assertTrue(startUpCalled);
      assertFalse(runCalled);
      assertFalse(shutDownCalled);
      runCalled = true;

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

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

- 12.8K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/ByteSourceTester.java

      suite.addTest(suiteForBytes(sliced, bytes, name + ".slice[long, long]", desc, false));

      // test a slice() of the ByteSource starting at a random offset with a length of
      // Long.MAX_VALUE
      ByteSourceFactory slicedLongMaxValue =
          SourceSinkFactories.asSlicedByteSourceFactory(factory, off, Long.MAX_VALUE);
      suite.addTest(

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

- Last Modified: Thu Mar 19 18:53:45 GMT 2026

- 8.6K bytes

- Click Count (0)

Search Options