Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for notifyFailed (0.29 sec)

  1. 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 =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  2. 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 =
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  3. 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"));
        }
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  4. 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"));
        }
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.9K bytes
    - Viewed (0)
  5. 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")
          /*
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  6. 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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  7. 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() {
          MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
              .execute(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 17 13:59:28 GMT 2023
    - 5.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                          }
                          notifyFailed(t);
                          return;
                        }
                      }
    
                      shutDown();
                      notifyStopped();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
            }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 7.6K bytes
    - Viewed (0)
Back to top