Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 375 for jstream (0.15 sec)

  1. src/main/java/org/codelibs/fess/util/InputStreamThread.java

                        }
                    }
                } catch (final Exception e) {
                    running = false;
                    if (logger.isDebugEnabled()) {
                        logger.debug("Failed to process an input stream.", e);
                    }
                }
            }
        }
    
        public String getOutput() {
            final StringBuilder buf = new StringBuilder(100);
            for (final String value : list) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/curl/CurlRequest.java

            }
            this.body = body;
            return this;
        }
    
        public CurlRequest body(final InputStream stream) {
            if (body != null) {
                throw new CurlException("body method is already called.");
            }
            this.bodyStream = stream;
            return this;
        }
    
        public CurlRequest onConnect(final BiConsumer<CurlRequest, HttpURLConnection> connectionBuilder) {
    Registered: Sun Oct 27 04:35:21 UTC 2024
    - Last Modified: Sun Feb 12 12:21:25 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  3. internal/deadlineconn/deadlineconn.go

    // Package deadlineconn implements net.Conn wrapper with configured deadlines.
    package deadlineconn
    
    import (
    	"net"
    	"time"
    )
    
    const updateInterval = 250 * time.Millisecond
    
    // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
    type DeadlineConn struct {
    	net.Conn
    	readDeadline  time.Duration // sets the read deadline on a connection.
    	readSetAt     time.Time
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.function.BiConsumer;
    import java.util.stream.Collectors;
    
    import org.codelibs.fess.app.service.WebConfigService;
    import org.codelibs.fess.es.client.SearchEngineClient;
    import org.codelibs.fess.es.config.exentity.WebConfig;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Wed Jul 24 08:54:24 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    // Note that upstream errors are currently not forwarded, but may be in the future.
    func (h *httpStreamResponse) Write(b []byte) (int, error) {
    	if len(b) == 0 || h.err != nil {
    		// Ignore 0 length blocks
    		return 0, h.err
    	}
    	tmp := make([]byte, len(b))
    	copy(tmp, b)
    	h.block <- tmp
    	return len(b), h.err
    }
    
    // CloseWithError will close the stream and return the specified error.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. cmd/object-api-getobjectinfo_test.go

    		{Bucket: "test-getobjectinfo", Name: "Asia/asiapics.jpg", ContentType: "image/jpeg", IsDir: false},
    		{Bucket: "test-getobjectinfo", Name: "Asia/empty-dir/", ContentType: "application/octet-stream", IsDir: true},
    	}
    	testCases := []struct {
    		bucketName string
    		objectName string
    
    		// Expected output of GetObjectInfo.
    		result ObjectInfo
    		err    error
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  7. docs/federation/lookup/Corefile.example

    . {
      etcd churchofminio.com {
          endpoint http://localhost:2379 http://localhost:4001
          upstream /etc/resolv.conf
      }
      debug
      prometheus
      cache 160 mydomain.com
      loadbalance
      forward . /etc/resolv.conf
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 16:53:08 UTC 2019
    - 216 bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            logger.info("After close response. Number of temp files: " + after);
    
            // ## Assert ##
            assertEquals(before, after);
        }
    
        private long countTmpFiles() {
            return Arrays.stream(Objects.requireNonNull(Curl.tmpDir.listFiles())).map(File::getName)
                    .filter(s -> s.startsWith(PREFIX) && s.endsWith(SUFFIX)).count();
        }
    Registered: Sun Oct 27 04:35:21 UTC 2024
    - Last Modified: Mon Nov 14 21:05:19 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  9. docs/logging/README.md

        "Content-Length": "401",
        "Content-Type": "application/octet-stream",
        "User-Agent": "MinIO (linux; amd64) minio-go/v7.0.70 mc/RELEASE.2024-04-30T17-44-48Z",
        "X-Amz-Content-Sha256": "STREAMING-AWS4-HMAC-SHA256-PAYLOAD",
        "X-Amz-Date": "20240509T073810Z",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 17:15:03 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java

     */
    package org.codelibs.fess.query;
    
    import java.io.IOException;
    import java.util.Objects;
    
    import org.apache.lucene.search.Query;
    import org.opensearch.core.common.io.stream.StreamOutput;
    import org.opensearch.core.xcontent.XContentBuilder;
    import org.opensearch.index.query.BoolQueryBuilder;
    import org.opensearch.index.query.DisMaxQueryBuilder;
    import org.opensearch.index.query.QueryBuilder;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top