- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 775 for readTo (0.46 sec)
-
cmd/object-api-putobject_test.go
CalculatedSHA256: "88d4266fd4e6338d13b845fcf289579d209c897823b9217da3e161936f031589", }, }, // Input with size more than the size of actual data inside the reader. 8: { bucketName: bucket, objName: object, inputData: []byte("abcd"), inputMeta: map[string]string{"etag": "e2fc714c4727ee9395f324cd2e7f331e"}, inputDataSize: int64(len("abcd") + 1),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BatchJobPrefix) DecodeMsg(dc *msgp.Reader) (err error) { var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err) return } if cap((*z)) >= int(zb0002) { (*z) = (*z)[:zb0002] } else {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 20.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HpackTest.kt
hpackWriter!!.writeHeaders(headerEntries("foo", "bar1")) assertBytes(0xbe) assertThat(hpackWriter!!.headerCount).isEqualTo(2) } private fun newReader(source: Buffer): Hpack.Reader = Hpack.Reader(source, 4096) private fun byteStream(vararg bytes: Int): Buffer = Buffer().write(intArrayToByteArray(bytes)) private fun checkEntry( entry: Header, name: String, value: String,
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 38.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt
var peek: String? = null while (true) { // Read a scheme name for this challenge if we don't have one already. if (peek == null) { skipCommasAndWhitespace() peek = readToken() if (peek == null) return } val schemeName = peek // Read a token68, a sequence of parameters, or nothing. val commaPrefixed = skipCommasAndWhitespace()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 7.2K bytes - Viewed (0) -
cmd/http-tracer.go
// http stats requests and audit if enabled. respRecorder := xhttp.NewResponseRecorder(w) // Setup a http request body recorder reqRecorder := &xhttp.RequestRecorder{Reader: r.Body} r.Body = reqRecorder // Create tracing data structure and associate it to the request context tc := mcontext.TraceCtxt{ AmzReqID: w.Header().Get(xhttp.AmzRequestID),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0) -
docs/es/docs/advanced/websockets.md
```console $ pip install websockets ---> 100% ``` </div> ## Cliente WebSockets { #websockets-client } ### En producción { #in-production } En tu sistema de producción, probablemente tengas un frontend creado con un framework moderno como React, Vue.js o Angular. Y para comunicarte usando WebSockets con tu backend probablemente usarías las utilidades de tu frontend.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 5.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2-legacy.go
return o, err } z.Flags = xlFlags(zb0003) } o = bts return o, err } // DecodeMsg implements msgp.Decodable func (z *xlMetaV2VersionHeaderV2) DecodeMsg(dc *msgp.Reader) (err error) { z.EcN, z.EcN = 0, 0 var zb0001 uint32 zb0001, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err) return err } if zb0001 != 5 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.8K bytes - Viewed (0) -
docs/es/docs/tutorial/body-updates.md
{* ../../docs_src/body_updates/tutorial002_py310.py hl[28:35] *} /// tip | Consejo Puedes realmente usar esta misma técnica con una operación HTTP `PUT`. Pero el ejemplo aquí usa `PATCH` porque fue creado para estos casos de uso. /// /// note | Nota Observa que el modelo de entrada sigue siendo validado.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 16 16:33:45 UTC 2025 - 5.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintStream; import java.io.PrintWriter; import java.io.Reader; import java.io.Serializable; import java.io.StringReader; import java.io.StringWriter; import java.io.Writer; import java.lang.reflect.AnnotatedElement; import java.lang.reflect.Array;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 21.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
assertEquals(-1, ArbitraryInstances.get(InputStream.class).read()); assertEquals(-1, ArbitraryInstances.get(ByteArrayInputStream.class).read()); assertEquals(-1, ArbitraryInstances.get(Readable.class).read(CharBuffer.allocate(1))); assertEquals(-1, ArbitraryInstances.get(Reader.class).read()); assertEquals(-1, ArbitraryInstances.get(StringReader.class).read()); assertEquals(0, ArbitraryInstances.get(Buffer.class).capacity());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 UTC 2025 - 22.6K bytes - Viewed (0)