- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 375 for jstream (0.16 sec)
-
cmd/untar.go
f: formatLZ4, }, { // Snappy/S2 stream header: []byte{0xff, 0x06, 0x00, 0x00}, f: formatS2, }, { header: []byte{0x42, 0x5a, 'h'}, f: formatBZ2, }, } type untarOptions struct { ignoreDirs bool ignoreErrs bool prefixAll string } // disconnectReader will ensure that no reads can take place on // the upstream reader after close has been called.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/OsddHelper.java
return osddFile != null; } public StreamResponse asStream() { if (osddFile == null) { throw ComponentUtil.getResponseManager().new404("Unsupported Open Search Description Document response."); } return new StreamResponse(osddFile.getName()).contentType(contentType + "; charset=" + encoding).stream(out -> { try (InputStream ins = new FileInputStream(osddFile)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.7K bytes - Viewed (0) -
.github/workflows/mint/nginx.conf
keepalive_timeout 65; # include /etc/nginx/conf.d/*.conf; upstream minio { server minio1:9000 max_fails=1 fail_timeout=10s; server minio2:9000 max_fails=1 fail_timeout=10s; server minio3:9000 max_fails=1 fail_timeout=10s; server minio4:9000 max_fails=1 fail_timeout=10s; } upstream console { ip_hash; server minio1:9001; server minio2:9001;
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 15 16:52:29 UTC 2024 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
BeanUtil.copyBeanToBean(form, entity, op -> op.exclude(Stream .concat(Stream.of(Constants.COMMON_CONVERSION_RULE), Stream.of(Constants.PERMISSIONS)).toArray(n -> new String[n]))); final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper(); entity.setPermissions(split(form.permissions, "\n").get(
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 18.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java
} // 404 throw responseManager.new404("Thumbnail for " + form.docId + " is under generating."); } return asStream(form.docId).contentType(getImageMimeType(thumbnailFile)).stream(out -> { try (BufferedInputStream in = new BufferedInputStream(new FileInputStream(thumbnailFile))) { out.write(in); } }); }
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.6K bytes - Viewed (0) -
.github/workflows/multipart/nginx-site1.conf
worker_processes auto; error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 4096; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"';
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Sep 30 10:13:56 UTC 2023 - 1.7K bytes - Viewed (0) -
.github/workflows/multipart/nginx-site2.conf
worker_processes auto; error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 4096; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"';
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Sep 30 10:13:56 UTC 2023 - 1.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
final String logFilePath = systemHelper.getLogFilePath(); if (StringUtil.isNotBlank(logFilePath)) { final Path logDirPath = Paths.get(logFilePath); try (Stream<Path> stream = Files.list(logDirPath)) { stream.filter(entry -> isLogFilename(entry.getFileName().toString())).forEach(filePath -> { final ZipEntry entry = new ZipEntry(id + "/" + filePath.getFileName().toString());
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 14K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/synonym/ApiAdminDictSynonymAction.java
body.dictId = dictId; validateApi(body, messages -> {}); return synonymService.getSynonymFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
} // NewDummyDataGen returns a ReadSeeker over the first `totalLength` // bytes from the infinite stream consisting of repeated // concatenations of `alphabets`. // // The skipOffset (generally = 0) can be used to skip a given number // of bytes from the beginning of the infinite stream. This is useful // to compare such streams of bytes that may be split up, because: // // Given the function: // // f := func(r io.Reader) string {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 4.7K bytes - Viewed (0)