Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 126 for observers (0.05 seconds)

  1. compat/maven-compat/src/test/java/org/apache/maven/artifact/resolver/TestTransferListener.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.artifact.resolver;
    
    import java.util.ArrayList;
    import java.util.List;
    
    import org.apache.maven.wagon.observers.AbstractTransferListener;
    
    public class TestTransferListener extends AbstractTransferListener {
    
        private final List<String> transfers = new ArrayList<>();
    
        public List<String> getTransfers() {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          assertSame(object, striped.getAt(i)); // idempotent
          observed.add(object);
        }
        assertTrue("All stripes observed", observed.size() == striped.size());
    
        // this uses #get(key), makes sure an already observed stripe is returned
        for (int i = 0; i < striped.size() * 100; i++) {
          assertTrue(observed.contains(striped.get(new Object())));
        }
    
        try {
          striped.getAt(-1);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          assertSame(object, striped.getAt(i)); // idempotent
          observed.add(object);
        }
        assertTrue("All stripes observed", observed.size() == striped.size());
    
        // this uses #get(key), makes sure an already observed stripe is returned
        for (int i = 0; i < striped.size() * 100; i++) {
          assertTrue(observed.contains(striped.get(new Object())));
        }
    
        try {
          striped.getAt(-1);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt

    import java.util.concurrent.TimeUnit
    
    /**
     * Observes, modifies, and potentially short-circuits requests going out and the corresponding
     * responses coming back in. Typically interceptors add, remove, or transform headers on the request
     * or response.
     *
     * Implementations of this interface throw [IOException] to signal connectivity failures. This
     * includes both natural exceptions such as unreachable servers, as well as synthetic exceptions
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndXResponse.java

                this.service = new String(buffer, bufferIndex, len, "ASCII");
            } catch (final UnsupportedEncodingException uee) {
                return 0;
            }
            bufferIndex += len + 1;
            // win98 observed not returning nativeFileSystem
            // Problems here with iSeries returning ASCII even though useUnicode = true
            // Fortunately we don't really need nativeFileSystem for anything.
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  6. docs/features/interceptors.md

    ```java
    /** This interceptor compresses the HTTP request body. Many webservers can't handle this! */
    final class GzipRequestInterceptor implements Interceptor {
      @Override public Response intercept(Interceptor.Chain chain) throws IOException {
        Request originalRequest = chain.request();
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 8.1K bytes
    - Click Count (0)
  7. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/crypto/DefaultSettingsDecryptionResult.java

    class DefaultSettingsDecryptionResult implements SettingsDecryptionResult {
    
        private List<Server> servers;
    
        private List<Proxy> proxies;
    
        private List<SettingsProblem> problems;
    
        DefaultSettingsDecryptionResult(List<Server> servers, List<Proxy> proxies, List<SettingsProblem> problems) {
            this.servers = (servers != null) ? servers : new ArrayList<>();
            this.proxies = (proxies != null) ? proxies : new ArrayList<>();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  8. docs/distributed/SIZING.md

    # Erasure code sizing guide
    
    ## Toy Setups
    
    Capacity constrained environments, MinIO will work but not recommended for production.
    
    | servers | drives (per node) | stripe_size | parity chosen (default) | tolerance for reads (servers) | tolerance for writes (servers) |
    |--------:|------------------:|------------:|------------------------:|------------------------------:|-------------------------------:|
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 3.9K bytes
    - Click Count (0)
  9. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/crypto/SettingsDecryptionRequest.java

    @Deprecated(since = "4.0.0")
    public interface SettingsDecryptionRequest {
    
        /**
         * Gets the servers whose passwords should be decrypted.
         *
         * @return The servers to decrypt, never {@code null}.
         */
        List<Server> getServers();
    
        /**
         * Sets the servers whose passwords should be decrypted.
         *
         * @param servers The servers to decrypt, may be {@code null}.
         * @return This request, never {@code null}.
         */
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java

            return this;
        }
    
        public ArtifactResolutionRequest setServers(List<Server> servers) {
            this.servers = servers;
    
            return this;
        }
    
        public List<Server> getServers() {
            if (servers == null) {
                servers = new ArrayList<>();
            }
    
            return servers;
        }
    
        public ArtifactResolutionRequest setMirrors(List<Mirror> mirrors) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 8.3K bytes
    - Click Count (0)
Back to Top