Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for awaitRunning (0.17 sec)

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

            thrownByExecutionThread);
      }
    
      public void testServiceStartStop() throws Exception {
        WaitOnRunService service = new WaitOnRunService();
        assertFalse(service.startUpCalled);
    
        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

     * @author Ben Yu
     */
    public class AbstractIdleServiceTest extends TestCase {
      public void testStart() {
        TestService service = new TestService();
        assertEquals(0, service.startUpCalled);
        service.startAsync().awaitRunning();
        assertEquals(1, service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

     * @author Ben Yu
     */
    public class AbstractIdleServiceTest extends TestCase {
      public void testStart() {
        TestService service = new TestService();
        assertEquals(0, service.startUpCalled);
        service.startAsync().awaitRunning();
        assertEquals(1, service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

            thrownByExecutionThread);
      }
    
      public void testServiceStartStop() throws Exception {
        WaitOnRunService service = new WaitOnRunService();
        assertFalse(service.startUpCalled);
    
        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      }
    
      /** @since 15.0 */
      @Override
      public final void awaitRunning() {
        delegate.awaitRunning();
      }
    
      /** @since 28.0 */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      /** @since 15.0 */
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

      }
    
      /** @since 15.0 */
      @Override
      public final void awaitRunning() {
        delegate.awaitRunning();
      }
    
      /** @since 28.0 */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      /** @since 15.0 */
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

                return delegate.stopAsync();
              }
    
              @Override
              public final void awaitRunning() {
                delegate.awaitRunning();
              }
    
              @Override
              public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
                delegate.awaitRunning(timeout, unit);
              }
    
              @Override
              public final void awaitTerminated() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
Back to top