- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 473 for readArg (0.23 sec)
-
src/encoding/base32/base32_test.go
// error is returned. {r: badReader{data: []byte("MY====="), errs: []error{badErr}}, res: "", err: badErr}, // Reader returns invalid input data (too short) but no error. Verify io.ErrUnexpectedEOF // is returned. {r: badReader{data: []byte("MY====="), errs: []error{nil}}, res: "", err: io.ErrUnexpectedEOF}, // Reader returns invalid input data and an error. Verify the reader and not the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 16:25:54 UTC 2024 - 26K bytes - Viewed (0) -
src/compress/flate/inflate.go
// The actual read interface needed by [NewReader]. // If the passed in io.Reader does not also have ReadByte, // the [NewReader] will introduce its own buffering. type Reader interface { io.Reader io.ByteReader } // Decompress state. type decompressor struct { // Input source. r Reader rBuf *bufio.Reader // created if provided io.Reader does not implement io.ByteReader roffset int64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 20.4K bytes - Viewed (0) -
cmd/update.go
return resp.Body, nil } var updateInProgress atomic.Uint32 // Function to get the reader from an architecture func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) { transport := getUpdateTransport(30 * time.Second) var reader io.ReadCloser if u.Scheme == "https" || u.Scheme == "http" { reader, err = getUpdateReaderFromURL(u, transport, mode) if err != nil { return nil, nil, err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
// returned on the STDOUT buffer. randomSize := 1024 * 1024 randomData := make([]byte, randomSize) if _, err := rand.Read(randomData); err != nil { t.Errorf("unexpected error reading random data: %v", err) } var stdout bytes.Buffer options := &remotecommand.StreamOptions{ Stdin: bytes.NewReader(randomData), Stdout: &stdout, } errorChan := make(chan error) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (this.errorCode == null) { this.errorCode = errorCode condition.signalAll() } } } /** * Returns true if read timeouts should be enforced while reading response headers or body bytes. * We always do timeouts in the HTTP server role. For clients, we only do timeouts after the * request is transmitted. This is only interesting for duplex calls where the request and
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/wasm/imagefetcher.go
func (k *wasmKeyChain) Resolve(target authn.Resource) (authn.Authenticator, error) { if bytes.Equal(k.data, []byte("null")) { // Filter out key chain with content "null" to prevent crash at underlying docker library. // Remove this check when https://github.com/docker/cli/pull/3434 is merged. return nil, fmt.Errorf("") } reader := bytes.NewReader(k.data)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Dec 10 05:44:51 UTC 2023 - 12K bytes - Viewed (0) -
src/crypto/ecdsa/ecdsa.go
// uses can use the [SignASN1] function in this package directly. func (priv *PrivateKey) Sign(rand io.Reader, digest []byte, opts crypto.SignerOpts) ([]byte, error) { return SignASN1(rand, priv, digest) } // GenerateKey generates a new ECDSA private key for the specified curve. // // Most applications should use [crypto/rand.Reader] as rand. Note that the // returned key does not depend deterministically on the bytes read from rand,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:11:18 UTC 2024 - 20.4K bytes - Viewed (0) -
src/os/pipe_test.go
// a blocked Read call on the reader side returns io.EOF. // // This scenario previously failed to unblock the Read call on darwin. // (See https://go.dev/issue/24164.) func testPipeEOF(t *testing.T, r io.ReadCloser, w io.WriteCloser) { // parkDelay is an arbitrary delay we wait for a pipe-reader goroutine to park // before issuing the corresponding write. The test should pass no matter what
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
src/regexp/exec_test.go
if line[0] == '#' || line[0] == '\n' { continue Reading } line = line[:len(line)-1] field := notab.FindAllString(line, -1) for i, f := range field { if f == "NULL" { field[i] = "" } if f == "NIL" { t.Logf("%s:%d: skip: %s", file, lineno, line) continue Reading } } if len(field) == 0 { continue Reading }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:36:03 UTC 2024 - 20.7K bytes - Viewed (0) -
src/encoding/json/scanner.go
} // stateDot0 is the state after reading the integer, decimal point, and subsequent // digits of a number, such as after reading `3.14`. func stateDot0(s *scanner, c byte) int { if '0' <= c && c <= '9' { return scanContinue } if c == 'e' || c == 'E' { s.step = stateE return scanContinue } return stateEndValue(s, c) } // stateE is the state after reading the mantissa and e in a number,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 16.1K bytes - Viewed (0)