Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for Observable (0.19 sec)

  1. guava/src/com/google/common/cache/Cache.java

       *
       * <p><b>Warning:</b> as with {@link CacheLoader#load}, {@code loader} <b>must not</b> return
       * {@code null}; it may either return a non-null value or throw an exception.
       *
       * <p>No observable state associated with this cache is modified until loading completes.
       *
       * @throws ExecutionException if a checked exception was thrown while loading the value
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Sun Aug 07 02:38:22 GMT 2022
    - 7.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/cache/Cache.java

       *
       * <p><b>Warning:</b> as with {@link CacheLoader#load}, {@code loader} <b>must not</b> return
       * {@code null}; it may either return a non-null value or throw an exception.
       *
       * <p>No observable state associated with this cache is modified until loading completes.
       *
       * @throws ExecutionException if a checked exception was thrown while loading the value
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Sun Aug 07 02:38:22 GMT 2022
    - 8.3K 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)
  8. android/guava/src/com/google/common/collect/Maps.java

         * expected</i>, but not absolutely required, to have the following properties:
         *
         * <ul>
         *   <li>Its execution does not cause any observable side effects.
         *   <li>The computation is <i>consistent with equals</i>; that is, {@link Objects#equal
         *       Objects.equal}{@code (k1, k2) &&} {@link Objects#equal}{@code (v1, v2)} implies that
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 159.6K bytes
    - Viewed (0)
  9. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    // Submitted by Piotr Zduniak <******@****.***>
    pcloud.host
    
    // NYC.mn : http://www.information.nyc.mn
    // Submitted by Matthew Brown <******@****.***>
    nyc.mn
    
    // Observable, Inc. : https://observablehq.com
    // Submitted by Mike Bostock <******@****.***>
    static.observableusercontent.com
    
    // Octopodal Solutions, LLC. : https://ulterius.io/
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 240.3K bytes
    - Viewed (3)
Back to top