- Sort Score
- Num 10 results
- Language All
Results 641 - 650 of 853 for Header (0.9 seconds)
-
cmd/bitrot-streaming.go
}() return bw } // ReadAt() implementation which verifies the bitrot hash available as part of the stream. type streamingBitrotReader struct { disk StorageAPI data []byte rc io.Reader volume string filePath string tillOffset int64 currOffset int64 h hash.Hash shardSize int64 hashBytes []byte } func (b *streamingBitrotReader) Close() error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jan 17 19:19:30 GMT 2025 - 6.2K bytes - Click Count (0) -
cmd/xl-storage-disk-id-check.go
func (p *xlStorageDiskIDCheck) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) (err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCreateFile, volume, path) if err != nil { return err } defer done(size, &err) return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader)) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
cmd/metacache-stream.go
return s2w.Close() } return nil } } var s2DecPool = bpool.Pool[*s2.Reader]{New: func() *s2.Reader { // Default alloc block for network transfer. return s2.NewReader(nil, s2.ReaderAllocBlock(16<<10)) }} // metacacheReader allows reading a cache stream. type metacacheReader struct { mr *msgp.Reader current metaCacheEntry err error // stateful error closer func()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 07 15:37:12 GMT 2025 - 19.5K bytes - Click Count (0) -
tests/test_repeated_cookie_headers.py
client = TestClient(app) def test_cookie_is_set_once(): direct_response = client.get("/directCookie") indirect_response = client.get("/indirectCookie") assert ( direct_response.headers["set-cookie"] == indirect_response.headers["set-cookie"]
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Jun 13 12:44:51 GMT 2020 - 792 bytes - Click Count (0) -
tests/test_security_oauth2_authorization_code_bearer_scopes_openapi.py
client = TestClient(app) def test_root(): response = client.get("/", headers={"Authorization": "Bearer testtoken"}) assert response.status_code == 200, response.text assert response.json() == {"message": "Hello World"} def test_read_with_oauth2_scheme(): response = client.get( "/with-oauth2-scheme", headers={"Authorization": "Bearer testtoken"} ) assert response.status_code == 200, response.text
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 6.6K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java
File file = new File(path); if (!file.exists()) { return Collections.emptyList(); } try (FileReader reader = new FileReader(file)) { List<UpgradedProperty> upgradedProperties = new Gson().fromJson(reader, new TypeToken<List<UpgradedProperty>>() {}.getType()); // FIXME There should be no duplicates, yet there are some return upgradedProperties.stream()
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Dec 24 14:15:15 GMT 2025 - 9.3K bytes - Click Count (0) -
src/bufio/scan_test.go
} err := s.Err() if err != nil { t.Errorf("#%d: %v", n, err) } } } // slowReader is a reader that returns only a few bytes at a time, to test the incremental // reads in Scanner.Scan. type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Click Count (0) -
tests/test_tutorial/test_security/test_tutorial001.py
assert response.headers["WWW-Authenticate"] == "Bearer" def test_token(client: TestClient): response = client.get("/items", headers={"Authorization": "Bearer testtoken"}) assert response.status_code == 200, response.text assert response.json() == {"token": "testtoken"} def test_incorrect_token(client: TestClient): response = client.get("/items", headers={"Authorization": "Notexistent testtoken"})
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 2.2K bytes - Click Count (0) -
internal/ioutil/wait_pipe.go
w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() } // CloseWithError close with supplied error the reader end func (r *PipeReader) CloseWithError(err error) error { err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Click Count (0) -
docs/es/docs/advanced/response-cookies.md
**FastAPI** utilizará ese response *temporal* para extraer las cookies (también los headers y el código de estado), y las pondrá en el response final que contiene el valor que devolviste, filtrado por cualquier `response_model`. También puedes declarar el parámetro `Response` en las dependencias, y establecer cookies (y headers) en ellas. ## Devolver una `Response` directamente { #return-a-response-directly }
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 2.5K bytes - Click Count (0)