Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1091 - 1100 of 1,233 for jstream (0.06 seconds)

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

     * </ul>
     */
    @SuppressWarnings({
      // We call threadUnexpectedException, which does the right thing for errors.
      "AssertionFailureIgnored",
      // We're following the upstream naming to reduce diffs.
      "IdentifierName",
      "ConstantCaseForConstants",
    })
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    abstract class JSR166TestCase extends TestCase {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

     * under the License.
     */
    package org.apache.maven.artifact.repository.metadata;
    
    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.nio.file.Files;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  3. README.md

    - **I/O Operations** (`org.codelibs.core.io`) - File handling, resource management, stream utilities, and traversal utilities for efficient resource processing
    - **Reflection** (`org.codelibs.core.lang`) - Class loading, method/field access, type introspection utilities, and generics support
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sun Aug 31 02:56:02 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/entity/FacetQueryViewTest.java

            assertEquals("filetype:doc", queryMap.get("DOC"));
    
            // Check no duplicate queries added to FacetInfo
            List<String> addedQueries = testFacetInfo.getAddedQueries();
            long pdfCount = addedQueries.stream().filter(q -> q.equals("filetype:pdf")).count();
            assertEquals(1, pdfCount);
        }
    
        // Test init() with empty file types
        @Test
        public void test_init_withEmptyFileTypes() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 17.9K bytes
    - Click Count (0)
  5. src/archive/tar/format.go

    	magicUSTAR, versionUSTAR = "ustar\x00", "00"
    	trailerSTAR              = "tar\x00"
    )
    
    // Size constants from various tar specifications.
    const (
    	blockSize  = 512 // Size of each block in a tar stream
    	nameSize   = 100 // Max length of the name field in USTAR format
    	prefixSize = 155 // Max length of the prefix field in USTAR format
    
    	// Max length of a special file (PAX header, GNU long name or link).
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/ImmutableMap.java

    import java.util.Spliterator;
    import java.util.Spliterators;
    import java.util.function.BiFunction;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Map} whose contents will never change, with many other important properties detailed at
     * {@link ImmutableCollection}.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 16:16:42 GMT 2026
    - 44.7K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

                    // Verify expected shares are present
                    List<String> shareList = List.of(shares);
                    boolean hasPublic = shareList.stream().anyMatch(s -> s.toLowerCase().contains("public"));
                    boolean hasShared = shareList.stream().anyMatch(s -> s.toLowerCase().contains("shared"));
    
                    assertTrue(hasPublic || hasShared, "Should contain expected shares");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 56K bytes
    - Click Count (0)
  8. cmd/erasure-multipart.go

    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    // them. This call is similar to single put operation but it is part
    // of the multipart transaction.
    //
    // Implements S3 compatible Upload Part API.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/Lists.java

       * this reason.
       *
       * <p><b>Java 8+ users:</b> many use cases for this method are better addressed by {@link
       * java.util.stream.Stream#map}. This method is not being deprecated, but we gently encourage you
       * to migrate to streams.
       */
      public static <F extends @Nullable Object, T extends @Nullable Object> List<T> transform(
          List<F> fromList, Function<? super F, ? extends T> function) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 16:38:09 GMT 2026
    - 42.5K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

                headerCount,
              )
              nextHeaderIndex += entriesToEvict
            }
            return entriesToEvict
          }
    
          /**
           * Read `byteCount` bytes of headers from the source stream. This implementation does not
           * propagate the never indexed flag of a header.
           */
          @Throws(IOException::class)
          fun readHeaders() {
            while (!source.exhausted()) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 23.2K bytes
    - Click Count (0)
Back to Top