Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for startAsync (0.15 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       *     method is called.
       */
      @CanIgnoreReturnValue
      public ServiceManager startAsync() {
        for (Service service : services) {
          checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
        }
        for (Service service : services) {
          try {
            state.tryStartTiming(service);
            service.startAsync();
          } catch (IllegalStateException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        service.startAsync().awaitRunning();
        assertEquals(State.RUNNING, service.state());
    
        service.stopAsync().awaitTerminated();
        assertEquals(State.TERMINATED, service.state());
      }
    
      public void testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait() throws Exception {
        NoOpService service = new NoOpService();
    
        service.startAsync().awaitRunning();
    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)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        service.startAsync().awaitRunning();
        assertEquals(State.RUNNING, service.state());
    
        service.stopAsync().awaitTerminated();
        assertEquals(State.TERMINATED, service.state());
      }
    
      public void testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait() throws Exception {
        NoOpService service = new NoOpService();
    
        service.startAsync().awaitRunning();
    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)
  4. src/test/java/org/codelibs/fess/api/WebApiRequestTest.java

            public ServletContext getServletContext() {
                return null;
            }
    
            @Override
            public AsyncContext startAsync() throws IllegalStateException {
                return null;
            }
    
            @Override
            public AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse) throws IllegalStateException {
                return null;
            }
    
            @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 17.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

              public final void addListener(Listener listener, Executor executor) {
                service1.startAsync();
                delegate.addListener(listener, executor);
              }
    
              // Delegates from here on down
              @Override
              public final Service startAsync() {
                return delegate.startAsync();
              }
    
              @Override
              public final Service stopAsync() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

              public final void addListener(Listener listener, Executor executor) {
                service1.startAsync();
                delegate.addListener(listener, executor);
              }
    
              // Delegates from here on down
              @Override
              public final Service startAsync() {
                return delegate.startAsync();
              }
    
              @Override
              public final Service stopAsync() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/filter/CorsFilterTest.java

                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync() {
                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync(jakarta.servlet.ServletRequest req, jakarta.servlet.ServletResponse res) {
                return null;
            }
    
            @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 22.6K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java

                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync() {
                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse) {
                    return null;
                }
    
                @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 26.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/filter/WebApiFilterTest.java

                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync() throws IllegalStateException {
                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse)
                        throws IllegalStateException {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 26.5K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/entity/SearchRequestParamsTest.java

                throw new UnsupportedOperationException();
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync() {
                throw new UnsupportedOperationException();
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync(jakarta.servlet.ServletRequest servletRequest,
                    jakarta.servlet.ServletResponse servletResponse) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 26.5K bytes
    - Click Count (0)
Back to Top