Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 147 for asStream (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top