Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 375 for jstream (0.09 sec)

  1. cmd/untar.go

    		f:      formatLZ4,
    	},
    	{
    		// Snappy/S2 stream
    		header: []byte{0xff, 0x06, 0x00, 0x00},
    		f:      formatS2,
    	},
    	{
    		header: []byte{0x42, 0x5a, 'h'},
    		f:      formatBZ2,
    	},
    }
    
    type untarOptions struct {
    	ignoreDirs bool
    	ignoreErrs bool
    	prefixAll  string
    }
    
    // disconnectReader will ensure that no reads can take place on
    // the upstream reader after close has been called.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/OsddHelper.java

            return osddFile != null;
        }
    
        public StreamResponse asStream() {
            if (osddFile == null) {
                throw ComponentUtil.getResponseManager().new404("Unsupported Open Search Description Document response.");
            }
    
            return new StreamResponse(osddFile.getName()).contentType(contentType + "; charset=" + encoding).stream(out -> {
                try (InputStream ins = new FileInputStream(osddFile)) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. .github/workflows/mint/nginx.conf

        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000 max_fails=1 fail_timeout=10s;
            server minio2:9000 max_fails=1 fail_timeout=10s;
            server minio3:9000 max_fails=1 fail_timeout=10s;
            server minio4:9000 max_fails=1 fail_timeout=10s;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
            server minio2:9001;
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java

                BeanUtil.copyBeanToBean(form, entity, 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: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java

                }
                // 404
                throw responseManager.new404("Thumbnail for " + form.docId + " is under generating.");
            }
    
            return asStream(form.docId).contentType(getImageMimeType(thumbnailFile)).stream(out -> {
                try (BufferedInputStream in = new BufferedInputStream(new FileInputStream(thumbnailFile))) {
                    out.write(in);
                }
            });
        }
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  6. .github/workflows/multipart/nginx-site1.conf

    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
                          '"$http_user_agent" "$http_x_forwarded_for"';
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 30 10:13:56 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. .github/workflows/multipart/nginx-site2.conf

    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
                          '"$http_user_agent" "$http_x_forwarded_for"';
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 30 10:13:56 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.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())).forEach(filePath -> {
                        final ZipEntry entry = new ZipEntry(id + "/" + filePath.getFileName().toString());
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 14K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/dict/synonym/ApiAdminDictSynonymAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return synonymService.getSynonymFile(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.1K bytes
    - Viewed (0)
  10. cmd/dummy-data-generator_test.go

    }
    
    // NewDummyDataGen returns a ReadSeeker over the first `totalLength`
    // bytes from the infinite stream consisting of repeated
    // concatenations of `alphabets`.
    //
    // The skipOffset (generally = 0) can be used to skip a given number
    // of bytes from the beginning of the infinite stream. This is useful
    // to compare such streams of bytes that may be split up, because:
    //
    // Given the function:
    //
    //	f := func(r io.Reader) string {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top