- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 104 for Streaming (0.08 sec)
-
docs/nl/docs/features.md
* **WebSocket** ondersteuning. * Taken in de achtergrond tijdens het proces. * Opstart- en afsluit events. * Test client gebouwd op HTTPX. * **CORS**, GZip, Statische bestanden, Streaming reacties. * **Sessie en Cookie** ondersteuning. * 100% van de code is getest. * 100% type geannoteerde codebase. ## Pydantic functionaliteit
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Sep 03 13:50:38 UTC 2024 - 10.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/HashFunction.java
* }</pre> */ 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); /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 25 18:22:59 UTC 2021 - 10.9K bytes - Viewed (0) -
guava/src/com/google/common/hash/HashFunction.java
* }</pre> */ 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); /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 25 18:22:59 UTC 2021 - 10.9K bytes - Viewed (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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
.assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)""")) .assertLogEqual("Content-Type: text/event-stream") .assertLogMatch(Regex("""Transfer-encoding: chunked""")) .assertLogEqual("<-- END HTTP (streaming)") .assertNoMoreLogs() applicationLogs .assertLogEqual("--> GET $url") .assertLogEqual("--> END GET") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 06 09:14:38 UTC 2024 - 37.6K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
// containing those values is emitted. func (d *Decoder) Recursive() *Decoder { d.emitRecursive = true return d } // Stream begins decoding from the underlying reader and returns a // streaming MetaValue channel for JSON values at the configured emitDepth. func (d *Decoder) Stream() chan *MetaValue { go d.decode() return d.metaCh } // Pos returns the number of bytes consumed from the underlying reader
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/metacache-stream.go
type metacacheBlockWriter struct { wg sync.WaitGroup streamErr error blockEntries int } // newMetacacheBlockWriter provides a streaming block writer. // Each block is the size of the capacity of the input channel. // The caller should close to indicate the stream has ended.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
docs/vi/docs/features.md
* Hỗ trợ **WebSocket**. * In-process background tasks. * Startup and shutdown events. * Client cho kiểm thử xây dựng trên HTTPX. * **CORS**, GZip, Static Files, Streaming responses. * Hỗ trợ **Session and Cookie**. * 100% test coverage. * 100% type annotated codebase. ## Tính năng của Pydantic
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/metacache-server-pool.go
} else { // Continue listing o.ID = c.id go c.keepAlive(ctx, rpc) } } } if o.ID != "" && !o.Transient { // We have an existing list ID, continue streaming. if o.Create { o.debugln("Creating", o) entries, err = z.listAndSave(ctx, o) if err == nil || err == io.EOF { return entries, err } entries.truncate(0) } else {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
To request this behaviour, your client software must enable the `WatchListClient` client-go feature gate. Additionally, streaming is only available if supported by the cluster; the API server that you connect to must also support streaming.
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Oct 29 20:17:52 UTC 2024 - 121.6K bytes - Viewed (0)