- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 195 for streaming (0.07 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)