- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for StreamReader (0.13 sec)
-
src/crypto/cipher/io.go
// The Stream* objects are so simple that all their members are public. Users // can create them themselves. // StreamReader wraps a [Stream] into an [io.Reader]. It calls XORKeyStream // to process each slice of data which passes through. type StreamReader struct { S Stream R io.Reader } func (r StreamReader) Read(dst []byte) (n int, err error) { n, err = r.R.Read(dst) r.S.XORKeyStream(dst[:n], dst[:n]) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 1.5K bytes - Viewed (0) -
src/net/http/roundtrip_js.go
} } var errClosed = errors.New("net/http: reader is closed") // streamReader implements an io.ReadCloser wrapper for ReadableStream. // See https://fetch.spec.whatwg.org/#readablestream for more information. type streamReader struct { pending []byte stream js.Value err error // sticky read error } func (r *streamReader) Read(p []byte) (n int, err error) { if r.err != nil { return 0, r.err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0) -
src/crypto/ecdh/ecdh_test.go
benchmarkAllCurves(b, func(b *testing.B, curve ecdh.Curve) { c, err := chacha20.NewUnauthenticatedCipher(make([]byte, 32), make([]byte, 12)) if err != nil { b.Fatal(err) } rand := cipher.StreamReader{ S: c, R: zeroReader, } peerKey, err := curve.GenerateKey(rand) if err != nil { b.Fatal(err) } peerShare := peerKey.PublicKey().Bytes() b.ResetTimer() b.ReportAllocs()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 18K bytes - Viewed (0) -
src/crypto/ecdsa/ecdsa.go
if err != nil { return nil, err } // Create a CSPRNG that xors a stream of zeros with // the output of the AES-CTR instance. const aesIV = "IV for ECDSA CTR" return &cipher.StreamReader{ R: zeroReader, S: cipher.NewCTR(block, []byte(aesIV)), }, nil } type zr struct{} var zeroReader = zr{} // Read replaces the contents of dst with zeros. It is safe for concurrent use.
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/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"NewCTR", Func, 0}, {"NewGCM", Func, 2}, {"NewGCMWithNonceSize", Func, 5}, {"NewGCMWithTagSize", Func, 11}, {"NewOFB", Func, 0}, {"Stream", Type, 0}, {"StreamReader", Type, 0}, {"StreamReader.R", Field, 0}, {"StreamReader.S", Field, 0}, {"StreamWriter", Type, 0}, {"StreamWriter.Err", Field, 0}, {"StreamWriter.S", Field, 0}, {"StreamWriter.W", Field, 0}, }, "crypto/des": {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)