- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 147 for asStream (0.04 seconds)
-
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
logger.debug("Backup download requested: id={}", id); } if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) { if ("system.properties".equals(id)) { return asStream(id).contentTypeOctetStream().stream(out -> { try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Nov 24 02:07:40 GMT 2025 - 32.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/OsddHelper.java
*/ public boolean hasOpenSearchFile() { return osddFile != null; } /** * Returns the OSDD as a stream response. * * @return the stream response */ public StreamResponse asStream() { if (osddFile == null) { throw ComponentUtil.getResponseManager().new404("Unsupported Open Search Description Document response."); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 4.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.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())).sorted().forEach(filePath -> { final Map<String, Object> map = new HashMap<>();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 23 23:57:26 GMT 2026 - 5.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/badword/AdminBadwordAction.java
*/ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) { verifyToken(this::asDownloadHtml); return asStream("badword.csv").contentTypeOctetStream().stream(out -> { final Path tempFile = ComponentUtil.getSystemHelper().createTempFile("fess-badword-", ".csv").toPath(); try {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 23 23:57:26 GMT 2026 - 18K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/design/AdminDesignAction.java
return null; } validate(form, messages -> {}, this::asListHtml); verifyTokenKeep(this::asListHtml); return asStream(file.getName()).contentTypeOctetStream().stream(out -> { try (FileInputStream fis = new FileInputStream(file)) { out.write(fis); } }); } /** * Delete a design file.Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 23 23:57:26 GMT 2026 - 20.1K bytes - Click Count (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(
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 23 23:57:26 GMT 2026 - 22.2K bytes - Click Count (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);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 23K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/OsddHelperTest.java
osddHelper.setContentType("application/opensearchdescription+xml"); osddHelper.init(); assertFalse(osddHelper.hasOpenSearchFile()); try { osddHelper.asStream(); fail(); } catch (final Exception e) { assertEquals("Unsupported Open Search Description Document response.", e.getMessage()); } } @Test
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 24.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/LlmChatRequest.java
*/ public boolean isStream() { return stream; } /** * Sets whether streaming is enabled. * * @param stream true to enable streaming * @return this request for method chaining */ public LlmChatRequest setStream(final boolean stream) { this.stream = stream; return this; } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 05 03:38:31 GMT 2026 - 6.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 92.3K bytes - Click Count (0)