Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 604 for streams (0.04 seconds)

  1. guava-testlib/test/com/google/common/testing/ClassSanityTesterTest.java

    import java.util.AbstractList;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit tests for {@link ClassSanityTester}.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 36.3K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/BridgeInterceptor.kt

          requestBuilder.header("Connection", "Keep-Alive")
        }
    
        // If we add an "Accept-Encoding: gzip" header field we're responsible for also decompressing
        // the transfer stream.
        var transparentGzip = false
        if (userRequest.header("Accept-Encoding") == null && userRequest.header("Range") == null) {
          transparentGzip = true
          requestBuilder.header("Accept-Encoding", "gzip")
        }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. okhttp-brotli/src/test/java/okhttp3/brotli/BrotliInterceptorTest.kt

          }
    
        assertFailsWith<IOException> {
          val failingResponse = brotliInterceptor.decompress(response)
          failingResponse.body.string()
        }.also { ioe ->
          assertThat(ioe).hasMessage("Brotli stream decoding failed")
          assertThat(ioe.cause?.javaClass?.simpleName).isEqualTo("BrotliRuntimeException")
        }
      }
    
      @Test
      fun testSkipUncompressNoContentResponse() {
        val response =
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Aug 22 08:12:58 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  4. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.settings.io;
    
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import java.nio.file.Files;
    import java.util.Map;
    import java.util.Objects;
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  5. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/cisupport/CIDetectorHelperTest.java

            ProcessBuilder processBuilder =
                    new ProcessBuilder(path, "-cp", classpath, CIDetectorHelperRunner.class.getName());
            processBuilder.environment().putAll(add);
            ALL.stream()
                    .filter(s -> !add.containsKey(s))
                    .forEach(k -> processBuilder.environment().remove(k));
            Process process = processBuilder.start();
            process.waitFor();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sun Apr 13 18:50:07 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/ImmutableMultiset.java

    import java.util.Collection;
    import java.util.Collections;
    import java.util.Iterator;
    import java.util.List;
    import java.util.function.Function;
    import java.util.function.ToIntFunction;
    import java.util.stream.Collector;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Multiset} whose contents will never change, with many other important properties
     * detailed at {@link ImmutableCollection}.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  7. docs/distributed/DECOMMISSION.md

    Decommissiong is a mechanism in MinIO to drain older pools (usually with old hardware) and migrate the content from such pools to a newer pools (usually better hardware). Decommissioning spreads the data across all pools - for example, if you decommission `pool1`, all the data from `pool1` spreads across `pool2` and `pool3`.
    
    ## Features
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jul 11 14:59:49 GMT 2022
    - 8.3K bytes
    - Click Count (0)
  8. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/DefaultToolchainsReader.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.toolchain.io;
    
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import java.nio.file.Files;
    import java.util.Map;
    import java.util.Objects;
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/LineReader.java

       * linefeed ({@code "\r\n"}).
       *
       * @return a {@code String} containing the contents of the line, not including any
       *     line-termination characters, or {@code null} if the end of the stream has been reached.
       * @throws IOException if an I/O error occurs
       */
      @CanIgnoreReturnValue // to skip a line
      public @Nullable String readLine() throws IOException {
        while (lines.peek() == null) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/collect/ImmutableMapEntrySet.java

      @J2ktIncompatible
        @Override
      Object writeReplace() {
        return new EntrySetSerializedForm<>(map());
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use EntrySetSerializedForm");
      }
    
      @GwtIncompatible
      @J2ktIncompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 3.7K bytes
    - Click Count (0)
Back to Top