- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 375 for jstream (0.15 sec)
-
src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java
protected String[] toStringArray(final Object value) { if (value instanceof String[]) { return (String[]) value; } else if (value instanceof List) { return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]); } String str = DfTypeUtil.toString(value); if (str == null) { return null; } return new String[] { str };
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
docs/pl/docs/features.md
* Eventy startup i shutdown. * Klient testowy zbudowany na bazie biblioteki `requests`. * **CORS**, GZip, pliki statyczne, streamy. * Obsługa **sesji i ciasteczek**. * 100% pokrycie testami. * 100% adnotacji typów. ## Cechy Pydantic
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/erasure-object.go
} return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil } // PutObject - creates an object upon reading from the input stream // until EOF, erasure codes the data across all disk and additionally // writes `xl.meta` which carries the necessary metadata for future // object operations.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 78.5K bytes - Viewed (0) -
src/archive/tar/reader_test.go
} data1, data2, pax, sparse := ss[0], ss[1], ss[2], ss[3] data2 += strings.Repeat("\x00", 10*512) trash := strings.Repeat("garbage ", 64) // Exactly 512 bytes vectors := []struct { input string // Input stream cnt int // Expected number of headers read err error // Expected error outcome }{ {"", 0, io.EOF}, // Empty file is a "valid" tar file {data1[:511], 0, io.ErrUnexpectedEOF},
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Oct 03 15:48:09 UTC 2024 - 46.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java
protected String[] toStringArray(final Object value) { if (value instanceof String[]) { return (String[]) value; } else if (value instanceof List) { return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]); } String str = DfTypeUtil.toString(value); if (str == null) { return null; } return new String[] { str };
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java
protected String[] toStringArray(final Object value) { if (value instanceof String[]) { return (String[]) value; } else if (value instanceof List) { return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]); } String str = DfTypeUtil.toString(value); if (str == null) { return null; } return new String[] { str };
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
cmd/handler-utils.go
return nil, err } } // Set content-type to default value if it is not set. if _, ok := metadata[strings.ToLower(xhttp.ContentType)]; !ok { metadata[strings.ToLower(xhttp.ContentType)] = "binary/octet-stream" } // https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w for k := range metadata { if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
} if isTruncated { listObjectsInfo.IsTruncated = true listObjectsInfo.NextContinuationToken = nextToken } return listObjectsInfo, nil } // getFilesFromZIPObject reads a partial stream of a zip file to build the zipindex.Files index func getFilesListFromZIPObject(ctx context.Context, objectAPI ObjectLayer, bucket, object string, opts ObjectOptions) (zipindex.Files, ObjectInfo, error) { size := 1 << 20
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream // is always going to be in-memory as we cannot re-read from what we // wrote to disk - since that amounts to "copying" from a "copy" // instead of "copying" from source, we need the stream to be seekable // to ensure that we can make fan-out calls concurrently. buf := bytebufferpool.Get()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 63.4K bytes - Viewed (0) -
cmd/storage-rest-client.go
select { case <-ctx.Done(): case updates <- *resp.Update: } } if resp.Final != nil { final = resp.Final } // We can't reuse the response since it is sent upstream. return nil }) if err != nil { return cache, toStorageErr(err) } if final == nil { return cache, errors.New("no final cache") } return *final, nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0)