- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 373 for asStream (0.11 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/dict/protwords/AdminDictProtwordsAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return protwordsService.getProtwordsFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 20.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
final String diagnosticId = "log" + new SimpleDateFormat("yyyyMMddHHmm").format(ComponentUtil.getSystemHelper().getCurrentTime()); return asStream(diagnosticId + ".zip").contentTypeOctetStream().stream(out -> { try (ZipOutputStream zos = new ZipOutputStream(out.stream())) { writeLogFiles(zos, diagnosticId); writeSystemProperties(zos, diagnosticId);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 18.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
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: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 20 13:56:35 UTC 2025 - 22.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return kuromojiService.getKuromojiFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 21.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stopwords/AdminDictStopwordsAction.java
*/ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) { validate(form, messages -> {}, () -> downloadpage(form.dictId)); verifyTokenKeep(() -> downloadpage(form.dictId)); return stopwordsService.getStopwordsFile(form.dictId)Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 20.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return stemmerOverrideService.getStemmerOverrideFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 23.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/synonym/AdminDictSynonymAction.java
* @return ActionResponse with the file download stream */ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) { validate(form, messages -> {}, () -> downloadpage(form.dictId)); verifyTokenKeep(() -> downloadpage(form.dictId)); return synonymService.getSynonymFile(form.dictId)Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 23.7K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/app/web/admin/dict/mapping/AdminDictMappingAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return charMappingService.getCharMappingFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 22.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStreamTest.java
IgnoreCloseInputStream stream = new IgnoreCloseInputStream(underlyingStream); // Read some data assertEquals('T', stream.read()); // Close should be ignored stream.close(); // Should still be able to read assertEquals('e', stream.read()); assertEquals('s', stream.read()); assertEquals('t', stream.read()); }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
* Executes the provided {@link Consumer} with a {@link Stream} obtained from the supplier. * The stream is automatically closed after the consumer is executed. * * @param stream the {@link Consumer} to process the {@link Stream} */ public void of(final Consumer<Stream<T>> stream) { try (Stream<T> s = supplier.get()) { stream.accept(s); } }Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 4.4K bytes - Viewed (0)