Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 881 - 890 of 1,152 for Ensure (0.14 seconds)

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

        for (int i = 0; i < 11; i++) {
          limiter.acquire(); // #7, showing off the warmup starting from totally cold
        }
    
        // make sure the areas (times) remain the same, while permits are different
        assertEvents(
            "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1
            "U4.50", // #2
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Hashing.java

        // Get the recommended table size.
        // Round down to the nearest power of 2.
        expectedEntries = max(expectedEntries, 2);
        int tableSize = Integer.highestOneBit(expectedEntries);
        // Check to make sure that we will not exceed the maximum load factor.
        if (expectedEntries > (int) (loadFactor * tableSize)) {
          tableSize <<= 1;
          return (tableSize > 0) ? tableSize : MAX_TABLE_SIZE;
        }
        return tableSize;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  3. compat/maven-compat/src/test/java/org/apache/maven/project/inheritance/t01/ProjectInheritanceTest.java

    import org.junit.jupiter.api.Test;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    
    /**
     * A test which demonstrates maven's recursive inheritance where
     * we are testing to make sure that elements stated in a model are
     * not clobbered by the same elements elsewhere in the lineage.
     *
     */
    @Deprecated
    class ProjectInheritanceTest extends AbstractProjectInheritanceTestCase {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue May 27 13:59:13 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // Wait for the listeners to be called, don't rely on the same-thread exec.
        listenerLatch.await(5, SECONDS);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
    
        // Make sure we didn't run anything.
        assertEquals(1, runLatch.getCount());
      }
    
      public void testListenerCalledOnCancelFromRunning() throws Exception {
        exec.execute(task);
        runLatch.await();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  5. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

        }
    
        /**
         * @see org.apache.maven.plugin.logging.Log#isDebugEnabled()
         */
        @Override
        public boolean isDebugEnabled() {
            // TODO Not sure how best to set these for this implementation...
            return false;
        }
    
        /**
         * @see org.apache.maven.plugin.logging.Log#isInfoEnabled()
         */
        @Override
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  6. docs/en/docs/advanced/middleware.md

    ```Python
    from unicorn import UnicornMiddleware
    
    app = SomeASGIApp()
    
    new_app = UnicornMiddleware(app, some_config="rainbow")
    ```
    
    But FastAPI (actually Starlette) provides a simpler way to do it that makes sure that the internal middlewares handle server errors and custom exception handlers work properly.
    
    For that, you use `app.add_middleware()` (as in the example for CORS).
    
    ```Python
    from fastapi import FastAPI
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 4.1K bytes
    - Click Count (0)
  7. docs/metrics/prometheus/alerts.md

        equal: ['alertname', 'dev', 'instance']
    ```
    
    This sample configuration uses a `webhook` at http://127.0.0.1:8010/webhook to post the alerts.
    Start the AlertManager and it listens on port `9093` by default. Make sure your webhook is up and listening for the alerts.
    
    ## Configure Prometheus to use AlertManager
    
    Add below section to your `prometheus.yml`
    ```yaml
    alerting:
      alertmanagers:
      - static_configs:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 23 15:13:23 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  8. internal/config/subnet/config.go

    	cfg.Proxy = proxy
    
    	if transport == nil {
    		// when transport is nil, it means we are just validating the
    		// inputs not performing any network calls.
    		return cfg, nil
    	}
    
    	// Make sure to clone the transport before editing the ProxyURL
    	if proxyURL != nil {
    		if tr, ok := transport.(*http.Transport); ok {
    			ctransport := tr.Clone()
    			ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  9. compat/maven-model-builder/src/test/java/org/apache/maven/model/interpolation/AbstractModelInterpolatorTest.java

            Calendar cal = Calendar.getInstance();
            cal.setTimeZone(MavenBuildTimestamp.DEFAULT_BUILD_TIME_ZONE);
            cal.set(Calendar.HOUR, 12);
            cal.set(Calendar.AM_PM, Calendar.AM);
    
            // just to make sure all the bases are covered...
            cal.set(Calendar.HOUR_OF_DAY, 0);
            cal.set(Calendar.MINUTE, 16);
            cal.set(Calendar.SECOND, 0);
            cal.set(Calendar.YEAR, 1976);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sun Mar 30 23:08:36 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // Wait for the listeners to be called, don't rely on the same-thread exec.
        listenerLatch.await(5, SECONDS);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
    
        // Make sure we didn't run anything.
        assertEquals(1, runLatch.getCount());
      }
    
      public void testListenerCalledOnCancelFromRunning() throws Exception {
        exec.execute(task);
        runLatch.await();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
Back to Top