Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 154 for react (0.26 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

                TimeoutException.class,
                () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS));
        assertThat(e)
            .hasMessageThat()
            .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state.");
      }
    
      private static class TestService extends AbstractIdleService {
        int startUpCalled = 0;
        int shutDownCalled = 0;
        final List<State> transitionStates = Lists.newArrayList();
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  2. cmd/bucket-notification-handlers.go

    					config.QueueList = append(config.QueueList[:i],
    						config.QueueList[i+1:]...)
    				}
    				// This is a one time activity we shall do this
    				// here and allow stale ARN to be removed. We shall
    				// never reach a stage where we will have stale
    				// notification configs.
    			}
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(config)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

                TimeoutException.class,
                () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS));
        assertThat(e)
            .hasMessageThat()
            .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state.");
      }
    
      private static class TestService extends AbstractIdleService {
        int startUpCalled = 0;
        int shutDownCalled = 0;
        final List<State> transitionStates = Lists.newArrayList();
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

          (if (isCanceled()) "canceled " else "") +
            (if (forWebSocket) "web socket" else "call") +
            " to " + redactedUrl()
        )
      }
    
      internal fun redactedUrl(): String = originalRequest.url.redact()
    
      inner class AsyncCall(
        private val responseCallback: Callback,
      ) : Runnable {
        @Volatile var callsPerHost = AtomicInteger(0)
          private set
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

            assertThrows(
                TimeoutException.class, () -> service.startAsync().awaitRunning(1, MILLISECONDS));
        assertThat(e)
            .hasMessageThat()
            .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state.");
      }
    
      private class TestService extends AbstractScheduledService {
        CyclicBarrier runFirstBarrier = new CyclicBarrier(2);
        CyclicBarrier runSecondBarrier = new CyclicBarrier(2);
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/ReaderInputStream.java

              } else if (endOfInput) { // (b)
                doneEncoding = true;
              } else { // (c)
                readMoreChars();
              }
            } else if (result.isError()) {
              // Only reach here if a CharsetEncoder with non-REPLACE settings is used.
              result.throwException();
              return 0; // Not called.
            }
          }
        }
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 28 20:13:02 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  7. docs/hotfixes.md

    lead to conflicts and the patch will not cleanly apply. Conflicts might be trivial which can be resolved easily, when conflicts seem to be non-trivial or touches the part of the code-base the developer is not confident - to get additional clarity reach out to #hack on MinIOHQ slack channel. Hasty changes must be avoided, minor fixes and logs may be added to hotfix branches but this should not be followed as practice.*
    
    Once the **patch** is successfully applied, developer must run tests to...
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  8. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc

            break;
          case FetchState::FINISHED:
            return TF_SetStatus(status, TF_OK, "");
        }
      }
      return TF_SetStatus(
          status, TF_INTERNAL,
          "Control flow should never reach the end of RamFileBlockCache::Fetch.");
    }
    
    int64_t RamFileBlockCache::Read(const std::string& filename, size_t offset,
                                    size_t n, char* buffer, TF_Status* status) {
      if (n == 0) {
    C++
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Thu Jul 16 01:39:09 GMT 2020
    - 11.1K bytes
    - Viewed (0)
  9. cmd/globals.go

    	globalDirSuffixWithSlash       = globalDirSuffix + slashSeparator
    
    	// Add new global values here.
    )
    
    const (
    	// Limit fields size (except file) to 1Mib since Policy document
    	// can reach that size according to https://aws.amazon.com/articles/1434
    	maxFormFieldSize = int64(1 * humanize.MiByte)
    
    	// The maximum allowed time difference between the incoming request
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/DiscreteDomain.java

      @CheckForNull
      public abstract C previous(C value);
    
      /**
       * Returns a signed value indicating how many nested invocations of {@link #next} (if positive) or
       * {@link #previous} (if negative) are needed to reach {@code end} starting from {@code start}.
       * For example, if {@code end = next(next(next(start)))}, then {@code distance(start, end) == 3}
       * and {@code distance(end, start) == -3}. As well, {@code distance(a, a)} is always zero.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 10.3K bytes
    - Viewed (0)
Back to top