Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 195 for streaming (0.06 seconds)

  1. docs/en/docs/features.md

    * **WebSocket** support.
    * In-process background tasks.
    * Startup and shutdown events.
    * Test client built on HTTPX.
    * **CORS**, GZip, Static Files, Streaming responses.
    * **Session and Cookie** support.
    * 100% test coverage.
    * 100% type annotated codebase.
    
    ## Pydantic features { #pydantic-features }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  2. docs/changelogs/changelog_4x.md

        above. See [Jetty's overview][jetty_8_252] of the API change and its consequences.
    
     *  New: `MultipartReader` is a streaming decoder for [MIME multipart (RFC 2045)][rfc_2045]
        messages. It complements `MultipartBody` which is our streaming encoder.
    
        ```kotlin
        val response: Response = call.execute()
        val multipartReader = MultipartReader(response.body!!)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  3. cmd/xl-storage_test.go

    func TestXLStorageVerifyFile(t *testing.T) {
    	// We test 4 cases:
    	// 1) Whole-file bitrot check on proper file
    	// 2) Whole-file bitrot check on corrupted file
    	// 3) Streaming bitrot check on proper file
    	// 4) Streaming bitrot check on corrupted file
    
    	// create xlStorage test setup
    	storage, path, err := newXLStorageTestSetup(t)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 66K bytes
    - Click Count (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

    import java.math.BigInteger
    import java.net.ProtocolException
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    import okio.ForwardingSource
    import okio.Source
    import okio.buffer
    
    /**
     * Streaming decoder of data encoded following Abstract Syntax Notation One (ASN.1). There are
     * multiple variants of ASN.1, including:
     *
     *  * DER: Distinguished Encoding Rules. This further constrains ASN.1 for deterministic encoding.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  5. internal/grid/README.md

    If the response contains shared data it will cause issues, since each unique response is reused.
    To disable this behavior, use `(SingleHandler).WithSharedResponse()` to disable it.
    
    ## Streaming Requests
    
    Streams consists of an initial request with payload and allows for full two-way communication between the client and server.
    
    The handler function has this signature.
    
    Sample handler:
    ```go
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  6. docs/en/docs/advanced/custom-response.md

    /// tip
    
    Instead of returning a `StreamingResponse` directly, you should probably follow the style in [Stream Data](./stream-data.md), it's much more convenient and handles cancellation behind the scenes for you.
    
    If you are streaming JSON Lines, follow the [Stream JSON Lines](../tutorial/stream-json-lines.md) tutorial.
    
    ///
    
    ### `FileResponse` { #fileresponse }
    
    Asynchronously streams a file as the response.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 11K bytes
    - Click Count (0)
  7. docs/en/docs/advanced/advanced-dependencies.md

    For example, if you had a database session in a dependency with `yield`, the `StreamingResponse` would not be able to use that session while streaming data because the session would have already been closed in the exit code after `yield`.
    
    This behavior was reverted in 0.118.0, to make the exit code after `yield` be executed after the response is sent.
    
    /// info
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/hash/HashFunction.java

       * }
       */
      Hasher newHasher();
    
      /**
       * Begins a new hash code computation as {@link #newHasher()}, but provides a hint of the expected
       * size of the input (in bytes). This is only important for non-streaming hash functions (hash
       * functions that need to buffer their whole input before processing any of it).
       */
      Hasher newHasher(int expectedInputSize);
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  9. internal/grid/manager.go

    		return ErrHandlerAlreadyExists
    	}
    
    	m.handlers.stateless[id] = &h
    	return nil
    }
    */
    
    // RegisterStreamingHandler will register a stateless handler that serves
    // two-way streaming requests.
    func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if debugPrint {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

       *   -X PUT \
       *   -H 'Authorization: Bearer token' \
       *   --data '{\"key\":\"value\"}'
       * ```
       *
       * **Note:** This will consume the request body. This may have side effects if the [RequestBody]
       * is streaming or can be consumed only once.
       */
      @JvmOverloads
      fun toCurl(includeBody: Boolean = true): String =
        buildString {
          append("curl ${url.toString().shellEscape()}")
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Oct 30 13:46:58 GMT 2025
    - 14.7K bytes
    - Click Count (1)
Back to Top