Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 751 - 760 of 987 for jstream (0.05 seconds)

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

  1. docs/features/calls.md

    ## [Requests](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-request/)
    
    Each HTTP request contains a URL, a method (like `GET` or `POST`), and a list of headers. Requests may also contain a body: a data stream of a specific content type.
    
    ## [Responses](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-response/)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 3.9K bytes
    - Click Count (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/services/RepositoryAwareRequest.java

                                + "Found " + repositories.size() + " repositories but only " + set.size()
                                + " unique entries.");
            }
            if (repositories.stream().anyMatch(Objects::isNull)) {
                throw new IllegalArgumentException(
                        "Repository list contains null entries. All repository entries must be non-null RemoteRepository instances.");
            }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 10 07:30:49 GMT 2025
    - 5K bytes
    - Click Count (0)
  3. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/rest/RestResourcesPlugin.java

                    task.setSourceResourceDir(
                        defaultSourceSet.getResources()
                            .getSrcDirs()
                            .stream()
                            .filter(f -> f.isDirectory() && f.getName().equals("resources"))
                            .findFirst()
                            .orElse(null)
                    );
                });
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Jun 23 09:36:58 GMT 2021
    - 6.4K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java

                @Override
                protected List<String> loadDataStoreNameList() {
                    // Return unsorted list to test sorting
                    return List.of("Zebra", "Apple", "Banana").stream().sorted().collect(java.util.stream.Collectors.toList());
                }
            };
    
            List<String> names = testFactory.loadDataStoreNameList();
            assertEquals(3, names.size());
            assertEquals("Apple", names.get(0));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/ImmutableSet.java

      /**
       * Returns a {@code Collector} that accumulates the input elements into a new {@code
       * ImmutableSet}. Elements appear in the resulting set in the encounter order of the stream; if
       * the stream contains duplicates (according to {@link Object#equals(Object)}), only the first
       * duplicate in encounter order will appear in the result.
       *
       * @since 21.0
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Nov 07 16:09:47 GMT 2025
    - 35.3K bytes
    - Click Count (0)
  6. cmd/test-utils_test.go

    		signature = hex.EncodeToString(sumHMAC(signingKey, []byte(stringToSign)))
    
    		stream = append(stream, []byte(fmt.Sprintf("%x", n)+";chunk-signature="+signature+"\r\n")...)
    		stream = append(stream, buffer[:n]...)
    		stream = append(stream, []byte("\r\n")...)
    
    		if n <= 0 {
    			break
    		}
    	}
    	req.Body = io.NopCloser(bytes.NewReader(stream))
    	return req, nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenPropertiesLoader.java

                            tokStarted = true;
                            tokBuf.append(tok.trim());
                            break;
                    }
                }
    
                // Handle case where end of token stream and
                // still got data
                if ((!exit) && (tokStarted)) {
                    retVal = tokBuf.toString();
                }
            }
    
            return optional ? "?" + retVal : retVal;
        }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 24 17:29:44 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LayeredOptions.java

            return collectMapIfPresentOrEmpty(Options::userProperties);
        }
    
        @Override
        public String source() {
            return String.format(
                    "layered(%s)", options.stream().map(Options::source).toList());
        }
    
        @Override
        public Optional<Boolean> showVersionAndExit() {
            return returnFirstPresentOrEmpty(Options::showVersionAndExit);
        }
    
        @Override
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Feb 26 17:31:44 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  9. internal/config/compress/compress.go

    	EnvCompressMimeTypes       = "MINIO_COMPRESSION_MIME_TYPES"
    
    	// Include-list for compression.
    	DefaultExtensions = ".txt,.log,.csv,.json,.tar,.xml,.bin"
    	DefaultMimeTypes  = "text/*,application/json,application/xml,binary/octet-stream"
    )
    
    // DefaultKVS - default KV config for compression settings
    var (
    	DefaultKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Sep 06 17:37:10 GMT 2025
    - 5K bytes
    - Click Count (0)
  10. internal/s3select/genmessage.go

    	buf.WriteByte(7)
    	buf.Write([]byte{0, 5})
    	buf.WriteString("event")
    
    	buf.WriteByte(13)
    	buf.WriteString(":content-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 24})
    	buf.WriteString("application/octet-stream")
    
    	buf.WriteByte(11)
    	buf.WriteString(":event-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 7})
    	buf.WriteString("Records")
    
    	fmt.Println(buf.Bytes())
    }
    
    // Continuation Message
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 4.4K bytes
    - Click Count (0)
Back to Top