Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 901 - 910 of 1,041 for jstream (0.09 seconds)

  1. fastapi/applications.py

                type[Response],
                Doc(
                    """
                    The default response class to be used.
    
                    Read more in the
                    [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/#default-response-class).
    
                    **Example**
    
                    ```python
                    from fastapi import FastAPI
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 176.3K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

              val exception =
                assertFailsWith<IOException> {
                  response.trailers()
                }
              assertThat(exception.message).isIn(
                "Socket closed", // HTTP/1.1
                "stream was reset: CANCEL", // HTTP/2
              )
            }
          assertThat(trailersDelay).isGreaterThan(250.milliseconds)
          assertThat(trailersDelay).isLessThan(750.milliseconds)
        }
      }
    
      @Test
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 08 21:45:04 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  3. 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 Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Click Count (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

    import java.util.Optional;
    import java.util.Set;
    import java.util.function.Consumer;
    import java.util.function.Supplier;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    import java.util.stream.StreamSupport;
    
    import org.apache.maven.model.Activation;
    import org.apache.maven.model.Build;
    import org.apache.maven.model.BuildBase;
    import org.apache.maven.model.Dependency;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 03 15:06:05 GMT 2025
    - 66.8K bytes
    - Click Count (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategy.java

    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.Comparator;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import eu.maveniverse.domtrip.Document;
    import eu.maveniverse.domtrip.Editor;
    import eu.maveniverse.domtrip.Element;
    import org.apache.maven.api.RemoteRepository;
    import org.apache.maven.api.Session;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 37K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/PermissionHelper.java

                try {
                    if (fileAttributeView instanceof final AclFileAttributeView aclFileAttributeView) {
                        aclFileAttributeView.getAcl().stream().forEach(acl -> {
                            final UserPrincipal principal = acl.principal();
                            if (logger.isDebugEnabled()) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Nov 13 05:54:52 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  7. 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: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sun Aug 31 02:56:02 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java

            }
            if (value instanceof String[]) {
                return (String[]) value;
            }
            if (value instanceof List) {
                return ((List<?>) value).stream().map(Object::toString).toArray(String[]::new);
            }
            if (value != null) {
                return new String[] { value.toString() };
            }
    
            return new String[0];
        }
    
        /**
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 14.9K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * response was received without TLS.
       */
      @get:JvmName("handshake") val handshake: Handshake?,
      /** Returns the HTTP headers. */
      @get:JvmName("headers") val headers: Headers,
      /**
       * Returns a non-null stream with the server's response. The returned value must be
       * [closed][ResponseBody] and may be consumed only once.
       *
       * If this is a [cacheResponse], [networkResponse], or [priorResponse], the server's response body
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K 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 Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
Back to Top