Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 375 for jstream (0.31 sec)

  1. .github/workflows/mint/nginx-8-node.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: Wed May 15 16:52:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    	start := time.Now()
    	stream, err := handler.Call(context.Background(), remoteConn, &testRequest{Num: 1, String: testPayload})
    	errFatal(err)
    	go func() {
    		defer close(stream.Requests)
    		for i := 0; i < payloads; i++ {
    			// t.Log("sending new client request")
    			stream.Requests <- &testRequest{Num: i, String: testPayload}
    		}
    	}()
    	var n int
    	err = stream.Results(func(resp *testResponse) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/api/admin/dict/protwords/ApiAdminDictProtwordsAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return protwordsService.getProtwordsFile(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)
  4. buildscripts/upgrade-tests/nginx.conf

    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    
    events {
        worker_connections  1024;
    }
    
    
    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: Sun Nov 21 18:41:30 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/admin/dict/kuromoji/ApiAdminDictKuromojiAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            return kuromojiService.getKuromojiFile(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.3K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/helper/OsddHelperTest.java

    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.codelibs.fess.util.ComponentUtil;
    import org.lastaflute.web.response.StreamResponse;
    import org.lastaflute.web.servlet.request.stream.WrittenStreamOut;
    
    public class OsddHelperTest extends UnitFessTestCase {
    
        public void test_init_nofile() {
            ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
                @Override
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. internal/grid/README.md

        conn := manager.Connection(host).Subroute("asubroute")
    	
        payload := []byte("request")
        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    	if err != nil {
            return err
        }
        // Read results from the stream
        err = stream.Results(func(result []byte) error {
            fmt.Println("Got result", string(result))
    
            // Return the response for reuse
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java

            });
    
            final EditBody body = createEditBody(entity);
            final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper();
            body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                    .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n")));
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  9. docs/orchestration/docker-compose/nginx.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000;
            server minio2:9000;
            server minio3:9000;
            server minio4:9000;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
            server minio2:9001;
            server minio3:9001;
            server minio4:9001;
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 05 06:32:39 UTC 2022
    - 3K bytes
    - Viewed (0)
  10. .github/workflows/mint/nginx-1-node.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
        }
    
        server {
            listen       9000;
            listen  [::]:9000;
            server_name  localhost;
    
            # To allow special characters in headers
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 31 21:38:10 UTC 2023
    - 2.8K bytes
    - Viewed (0)
Back to top