- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 288 for readInt (0.13 seconds)
-
cmd/dummy-data-generator_test.go
n2, e2 := io.ReadFull(r2, b2) if n1 != n2 { return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2) } if !bytes.Equal(b1[:n1], b2[:n2]) { return false, fmt.Sprintf("After reading %d equal buffers (32Kib each), we got the following two strings:\n%v\n%v\n", i, b1, b2) } // Check if stream has ended if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.8K bytes - Click Count (0) -
src/archive/zip/struct.go
// Copyright 2010 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. /* Package zip provides support for reading and writing ZIP archives. See the [ZIP specification] for details. This package does not support disk spanning. A note about ZIP64: To be backwards compatible the FileHeader has both 32 and 64 bit Size
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue May 28 21:41:09 GMT 2024 - 12.1K bytes - Click Count (0) -
cmd/http-tracer_test.go
httpStats := newHTTPStats() // Simulate the concurrent scenario from the original race condition: // Multiple HTTP request handlers updating stats concurrently, // while background processes are reading the stats for persistence. const numWriters = 100 // Simulate many HTTP request handlers. const numReaders = 50 // Simulate background stats readers. const opsPerGoroutine = 100 var wg sync.WaitGroup
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.3K bytes - Click Count (0) -
docs/features/calls.md
Calls can be canceled from any thread. This will fail the call if it hasn’t yet completed! Code that is writing the request body or reading the response body will suffer an `IOException` when its call is canceled. ## Dispatch
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
return new String(buffer, 0, bufIndex); } // otherwise we got the size wrong. This can happen if the size changes between when // we called sizeIfKnown and when we started reading the file (or I guess if // maxCharsPerByte is wrong) // Fallback to an incremental approach StringBuilder builder = new StringBuilder(bufIndex + 32);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/s3select/simdj/reader.go
dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Click Count (0) -
docs/en/docs/advanced/security/oauth2-scopes.md
Nevertheless, you still enforce those scopes, or any other security/authorization requirement, however you need, in your code. In many cases, OAuth2 with scopes can be an overkill. But if you know you need it, or you are curious, keep reading. /// ## OAuth2 scopes and OpenAPI { #oauth2-scopes-and-openapi } The OAuth2 specification defines "scopes" as a list of strings separated by spaces.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 10:49:48 GMT 2025 - 13.5K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
public fun onRequestStart(socketEffect: SocketEffect?): Builder = apply { this.onRequestStart = socketEffect } /** * Process the response without even attempting to reading the request body. For HTTP/2 this * will close the response stream after the response body or trailers. For HTTP/1 this will * close the socket after the response body or trailers. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 17.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EnumHashBiMap.java
stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading field populated by writeObject @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 5.2K bytes - Click Count (0) -
cmd/api-response_test.go
resp := rw.Result() if resp.StatusCode != 123 { t.Fatalf("unexpected status: %v", resp.StatusCode) } body, err := io.ReadAll(resp.Body) if err != nil { t.Fatalf("reading response body failed: %v", err) } if string(body) != "hello" { t.Fatalf("response body incorrect: %v", string(body)) } // Check that Unwrap works if trw.Unwrap() != rw {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 5.8K bytes - Click Count (0)