Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 375 for jstream (0.1 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/dict/mapping/ApiAdminDictMappingAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return charMappingService.getCharMappingFile(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.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return stemmerOverrideService.getStemmerOverrideFile(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.5K bytes
    - Viewed (0)
  3. internal/grid/msg.go

    	OpMuxServerMsg
    
    	// OpUnblockSrvMux contains a message that a server mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockSrvMux
    
    	// OpUnblockClMux contains a message that a client mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockClMux
    
    	// OpAckMux acknowledges a mux was created.
    	OpAckMux
    
    	// OpRequest is a single request + response.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/log/ApiAdminLogAction.java

            if (StringUtil.isNotBlank(logFilePath) && isLogFilename(filename)) {
                final Path path = Paths.get(logFilePath, filename);
                return asStream(filename).contentTypeOctetStream().stream(out -> {
                    try (InputStream in = Files.newInputStream(path)) {
                        out.write(in);
                    }
                });
            }
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stopwords/ApiAdminDictStopwordsAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return stopwordsService.getStopwordsFile(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.2K bytes
    - Viewed (0)
  6. docs/hotfixes.md

    ```
    λ git checkout RELEASE.2021-04-22T15-44-28Z
    ```
    
    Create a branch and proceed to push the branch **upstream**
    > (upstream here points to ******@****.***:minio/minio.git)
    
    ```
    λ git branch -m RELEASE.2021-04-22T15-44-28Z.hotfix
    λ git push -u upstream RELEASE.2021-04-22T15-44-28Z.hotfix
    ```
    
    Pick the relevant commit-id say for example commit-id from the master branch
    
    ```
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Feb 14 21:36:02 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/api/admin/badword/ApiAdminBadwordAction.java

        }
    
        // GET /api/admin/badword/download
        @Execute
        public StreamResponse get$download(final DownloadBody body) {
            validateApi(body, messages -> {});
            return asStream("badword.csv").contentTypeOctetStream().stream(out -> {
                final Path tempFile = ComponentUtil.getSystemHelper().createTempFile("fess-badword-", ".csv").toPath();
                try {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/esreq/AdminEsreqAction.java

                        }
                        throw e1;
                    }
                    return asStream("es_" + ComponentUtil.getSystemHelper().getCurrentTimeAsLong() + ".json").contentTypeOctetStream()
                            .stream(out -> {
                                try (final InputStream in = new FileInputStream(tempFile)) {
                                    out.write(in);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    	if publicKey != nil {
    		w.WriteHeader(200)
    		stream := estream.NewWriter(w)
    		defer stream.Close()
    
    		clusterKey, err := bytesToPublicKey(getSubnetAdminPublicKey())
    		if err != nil {
    			bugLogIf(ctx, stream.AddError(err.Error()))
    			return
    		}
    		err = stream.AddKeyEncrypted(clusterKey)
    		if err != nil {
    			bugLogIf(ctx, stream.AddError(err.Error()))
    			return
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/storage/ApiAdminStorageAction.java

            if (StringUtil.isEmpty(pi.getName())) {
                throwValidationErrorApi(messages -> messages.addErrorsStorageFileNotFound(GLOBAL));
            }
            return asStream(pi.getName()).contentTypeOctetStream().stream(out -> {
                try {
                    downloadObject(getObjectName(pi.getPath(), pi.getName()), out);
                } catch (final StorageException e) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top