Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Observable (0.33 sec)

  1. guava-testlib/src/com/google/common/testing/GcFinalization.java

       * processing and may run concurrently, for example, if the JVM flag {@code
       * -XX:+ExplicitGCInvokesConcurrent} is used.
       *
       * <p>Whenever possible, it is preferable to test directly for some observable change resulting
       * from GC, as with {@link #awaitClear}. Because there are no guarantees for the order of GC
       * finalization processing, there may still be some unfinished work for the GC to do after this
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        manager.stopAsync().awaitStopped();
        assertFalse(manager.isHealthy());
        assertTrue(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
        // check that our NoOpService is not directly observable via any of the inspection methods or
        // via logging.
        assertEquals("ServiceManager{services=[]}", manager.toString());
        assertTrue(manager.servicesByState().isEmpty());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * called multiple times.
       *
       * <p>When this method is called {@link #state()} will return {@link State#STOPPING}, which is the
       * external state observable by the caller of {@link #stopAsync}.
       *
       * @since 27.0
       */
      @ForOverride
      protected void doCancelStart() {}
    
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
    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)
  4. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

       * processing and may run concurrently, for example, if the JVM flag {@code
       * -XX:+ExplicitGCInvokesConcurrent} is used.
       *
       * <p>Whenever possible, it is preferable to test directly for some observable change resulting
       * from GC, as with {@link #awaitClear}. Because there are no guarantees for the order of GC
       * finalization processing, there may still be some unfinished work for the GC to do after this
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            .contains("Exception thrown from implementation: class java.lang.StackOverflowError");
      }
    
      // Regression test for a case where we would fail to execute listeners immediately on done futures
      // this would be observable from an afterDone callback
      public void testListenersExecuteImmediately_fromAfterDone() {
        AbstractFuture<String> f =
            new AbstractFuture<String>() {
              @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        manager.stopAsync().awaitStopped();
        assertFalse(manager.isHealthy());
        assertTrue(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
        // check that our NoOpService is not directly observable via any of the inspection methods or
        // via logging.
        assertEquals("ServiceManager{services=[]}", manager.toString());
        assertTrue(manager.servicesByState().isEmpty());
    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)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            .contains("Exception thrown from implementation: class java.lang.StackOverflowError");
      }
    
      // Regression test for a case where we would fail to execute listeners immediately on done futures
      // this would be observable from an afterDone callback
      public void testListenersExecuteImmediately_fromAfterDone() {
        AbstractFuture<String> f =
            new AbstractFuture<String>() {
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top