Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1061 - 1070 of 1,233 for jstream (0.04 seconds)

  1. docs/contribute/code_of_conduct.md

     * **Be collaborative**: Collaboration reduces redundancy and improves the quality of our work. We
       strive for transparency within our open source community, and we work closely with upstream
       developers and others in the free software community to coordinate our efforts.
    
     * **Be pragmatic**: Questions are encouraged and should be asked early in the process to avoid
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 5.1K bytes
    - Click Count (0)
  2. src/main/java/jcifs/util/SmbCircuitBreaker.java

            if (!responseTimeHistory.isEmpty()) {
                long sum = responseTimeHistory.stream().mapToLong(Long::longValue).sum();
                avgResponseTime.set(sum / responseTimeHistory.size());
    
                // Calculate 95th percentile
                long[] sortedTimes = responseTimeHistory.stream().mapToLong(Long::longValue).sorted().toArray();
                int p95Index = (int) Math.ceil(0.95 * sortedTimes.length) - 1;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  3. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

    import java.util.Optional;
    import java.util.Set;
    import java.util.function.Consumer;
    import java.util.function.Supplier;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    import java.util.stream.StreamSupport;
    
    import org.apache.maven.model.Activation;
    import org.apache.maven.model.Build;
    import org.apache.maven.model.BuildBase;
    import org.apache.maven.model.Dependency;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 03 15:06:05 GMT 2025
    - 66.8K bytes
    - Click Count (0)
  4. cmd/erasure-sets.go

    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/CommonsCliOptions.java

            public static final String ALTERNATE_INSTALLATION_TOOLCHAINS = "it";
            public static final String LOG_FILE = "l";
            public static final String RAW_STREAMS = "raw-streams";
            public static final String COLOR = "color";
            public static final String OFFLINE = "o";
            public static final String HELP = "h";
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Oct 08 07:36:42 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  6. api/maven-api-model/src/main/mdo/maven.mdo

         */
        public String toString() {
            return "PatternSet [" +
                "includes: {" + getIncludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}, " +
                "excludes: {" + getExcludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}]";
        }
                ]]>
              </code>
            </codeSegment>
          </codeSegments>
        </class>
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 17 09:48:21 GMT 2026
    - 133.5K bytes
    - Click Count (0)
  7. src/main/webapp/WEB-INF/orig/view/chat/chat.jsp

    	<script type="text/javascript" src="${fe:url('/js/chat.js')}"></script>
    	<script type="text/javascript">
    		$(function() {
    			FessChat.init({
    				apiUrl: '${fe:url('/api/v1/chat')}',
    				streamUrl: '${fe:url('/api/v1/chat/stream')}',
    				labels: {
    					thinking: '<la:message key="labels.chat_thinking" />',
    					waiting: '<la:message key="labels.chat_waiting" />',
    					error: '<la:message key="labels.chat_error" />',
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 06:21:57 GMT 2026
    - 10.4K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/it/admin/FailureUrlTests.java

            response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();
            List<Map<String, Object>> afterLogs = JsonPath.from(response).getList("response.logs");
    
            boolean logDeleted = afterLogs.stream().noneMatch(log -> logId.equals(log.get("id").toString()));
            assertTrue(logDeleted, "Log should be deleted");
    
            logger.info("[END] testDeleteFailureUrlLog");
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/helper/PermissionHelper.java

                try {
                    if (fileAttributeView instanceof final AclFileAttributeView aclFileAttributeView) {
                        aclFileAttributeView.getAcl().stream().forEach(acl -> {
                            final UserPrincipal principal = acl.principal();
                            if (logger.isDebugEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 13 05:54:52 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java

                // Verify we still have only one process for this session
                Set<String> sessionIds = processHelper.getRunningSessionIdSet();
                assertEquals(1, sessionIds.stream().filter(id -> id.equals(sessionId)).count());
    
                // Clean up
                processHelper.destroyProcess(sessionId);
            } catch (Exception e) {
                fail("Unexpected exception: " + e.getMessage());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16K bytes
    - Click Count (0)
Back to Top