Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 373 for asStream (0.11 sec)

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