Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 162 for spreading (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. CONTRIBUTING.md

    * Keep commits discrete. Avoid including multiple unrelated changes in a single commit.
    * Keep commits self-contained. Avoid spreading a single change across multiple commits. A single commit should make sense in isolation.
    
    ### Testing changes
    
    After making changes, you can test your code in 2 ways:
    
    #### Run tests
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Mar 27 18:43:39 GMT 2026
    - 19.1K bytes
    - Click Count (0)
  2. cmd/streaming-signature-v4.go

    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // Streaming AWS Signature Version '4' constants.
    const (
    	emptySHA256                   = "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"
    	streamingContentSHA256        = "STREAMING-AWS4-HMAC-SHA256-PAYLOAD"
    	streamingContentSHA256Trailer = "STREAMING-AWS4-HMAC-SHA256-PAYLOAD-TRAILER"
    	signV4ChunkedAlgorithm        = "AWS4-HMAC-SHA256-PAYLOAD"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/suggest/analysis/SuggestAnalyzerTest.java

                        if (japaneseMode && "ja".equals(lang)) {
                            // Simulate Japanese reading conversion
                            testToken.setReading(convertToJapaneseReading(testToken.getTerm()));
                        } else {
                            // Default: uppercase for reading
                            testToken.setReading(testToken.getTerm().toUpperCase());
                        }
                    }
                }
    
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Sep 01 13:33:03 GMT 2025
    - 15.7K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/opensearch/config/bsentity/dbmeta/ElevateWordDbm.java

                false, false, false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
        protected final ColumnInfo _columnReading = cci("reading", "reading", null, null, String.class, "reading", null, false, false, false,
                "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/ErrorReportingTestListener.java

                        // It's not explicit what the threading guarantees are for TestListener method execution so we'll
                        // be explicitly safe here to avoid interleaving output from multiple test suites
                        synchronized (this) {
                            // make sure we've flushed everything to disk before reading
                            eventWriter.flush();
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 10.7K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        carrier.cancel()
      }
    
      /**
       * Prepares the HTTP headers and sends them to the server.
       *
       * For streaming requests with a body, headers must be prepared **before** the output stream has
       * been written to. Otherwise the body would need to be buffered!
       *
       * For non-streaming requests with a body, headers must be prepared **after** the output stream
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  7. src/test/java/org/codelibs/fess/suggest/request/suggest/SuggestRequestQueryBuildingTest.java

                    // because the code calls clear() on the returned list
                    List<String> result = new ArrayList<>();
                    result.add(text);
                    result.add(text + "_reading");
                    return result;
                }
            };
            request.setReadingConverter(converter);
    
            QueryBuilder result = request.buildQuery("test", Collections.emptyList());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  8. internal/event/target/nats.go

    	connOpts := []stan.Option{stan.NatsURL(addressURL)}
    	if n.Streaming.MaxPubAcksInflight > 0 {
    		connOpts = append(connOpts, stan.MaxPubAcksInflight(n.Streaming.MaxPubAcksInflight))
    	}
    	if n.UserCredentials != "" {
    		connOpts = append(connOpts, stan.NatsOptions(nats.UserCredentials(n.UserCredentials)))
    	}
    
    	return stan.Connect(n.Streaming.ClusterID, clientID, connOpts...)
    }
    
    // NATSTarget - NATS target.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/llm/LlmClientManager.java

                throw new LlmException("LLM chat request failed", e);
            }
        }
    
        /**
         * Performs a streaming chat completion request using the configured LLM client.
         *
         * @param request the chat request
         * @param callback the callback to receive streaming chunks
         * @throws LlmException if LLM is not available or an error occurs
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 11:10:51 GMT 2026
    - 17.4K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt

     * It can even stream a response larger than the total storage on the current device, which is a
     * common requirement for video streaming applications.
     *
     * Because this class does not buffer the full response in memory, the application may not
     * re-read the bytes of the response. Use this one shot to read the entire response into memory with
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:51:25 GMT 2025
    - 11.6K bytes
    - Click Count (0)
Back to Top