Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for notifyFailed (0.07 seconds)

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

       * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
       * or after it has returned. If startup fails, the invocation should cause a call to {@link
       * #notifyFailed(Throwable)} instead.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service startup, even when {@link #startAsync} is
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              toReturn = new FutureAsCancellable(immediateCancelledFuture());
            } finally {
              lock.unlock();
            }
            // Call notifyFailed outside the lock to avoid lock ordering issues.
            if (scheduleFailure != null) {
              service.notifyFailed(scheduleFailure);
            }
            return toReturn;
          }
    
          @GuardedBy("lock")
          /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

                    try {
                      startUp();
                      notifyStarted();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
        }
    
        @Override
        protected final void doStop() {
          renamingDecorator(executor(), threadNameSupplier)
              .execute(
                  () -> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                          }
                          notifyFailed(t);
                          return;
                        }
                      }
    
                      shutDown();
                      notifyStopped();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
            }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        @Override
        protected void doStart() {
          notifyFailed(new IllegalStateException("start failure"));
        }
      }
    
      private static class FailRunService extends NoOpService {
        @Override
        protected void doStart() {
          super.doStart();
          notifyFailed(new IllegalStateException("run failure"));
        }
      }
    
    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

        @Override
        protected void doStart() {
          notifyFailed(new IllegalStateException("start failure"));
        }
      }
    
      private static class FailRunService extends NoOpService {
        @Override
        protected void doStart() {
          super.doStart();
          notifyFailed(new IllegalStateException("run failure"));
        }
      }
    
    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. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

         * its state history.
         */
        RecordingListener unused = RecordingListener.record(service);
        service.startAsync();
        service.notifyFailed(new Exception("1"));
        service.notifyFailed(new Exception("2"));
        assertThat(service.failureCause()).hasMessageThat().isEqualTo("1");
        IllegalStateException e = assertThrows(IllegalStateException.class, service::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)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

         * its state history.
         */
        RecordingListener unused = RecordingListener.record(service);
        service.startAsync();
        service.notifyFailed(new Exception("1"));
        service.notifyFailed(new Exception("2"));
        assertThat(service.failureCause()).hasMessageThat().isEqualTo("1");
        IllegalStateException e = assertThrows(IllegalStateException.class, service::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)
Back to Top