- Sort Score
- Num 10 results
- Language All
Results 441 - 450 of 1,233 for jstream (0.05 seconds)
-
android/guava-tests/test/com/google/common/collect/CollectSpliteratorsTest.java
import com.google.common.collect.testing.SpliteratorTester; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Spliterator; import java.util.stream.DoubleStream; import java.util.stream.IntStream; import java.util.stream.LongStream; import junit.framework.TestCase; import org.jspecify.annotations.NullMarked; /** Tests for {@code CollectSpliterators}. */ @GwtCompatible @NullMarkedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 4.1K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsWriter.java
void write(Writer output, Map<String, Object> options, Settings settings) throws IOException; /** * Writes the supplied settings to the specified byte stream. The stream will be automatically closed before the * method returns. * * @param output The stream to serialize the settings to, must not be {@code null}. * @param options The options to use for serialization, may be {@code null} to use the default values.
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java
import java.io.IOException; import java.nio.file.Files; import java.nio.file.attribute.PosixFileAttributeView; import java.nio.file.attribute.PosixFilePermission; import java.util.List; import java.util.Set; import java.util.stream.Collectors; import org.apache.tools.ant.taskdefs.condition.Os; import org.gradle.api.DefaultTask; import org.gradle.api.GradleException; import org.gradle.api.file.FileCollection; import org.gradle.api.file.FileTree;
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java
public void init() { if (logger.isDebugEnabled()) { logger.debug("Initializing {}", this.getClass().getSimpleName()); } stream(ComponentUtil.getFessConfig().getSearchDefaultPermissionsAsArray()).of(stream -> stream.forEach(name -> { defaultRoleList.add(name); })); } /** * Builds a set of roles from the request.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 15.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/SessionSetupHandlerTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.verifyNoInteractions; import java.lang.reflect.Modifier; import java.util.stream.Stream; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.3K bytes - Click Count (0) -
internal/config/crypto_test.go
if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } data, err := io.ReadAll(ciphertext) if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context) if err != nil { t.Fatalf("Test %d: failed to decrypt stream: %v", i, err) } data, err = io.ReadAll(plaintext) if err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/synonym/AdminDictSynonymAction.java
* @return ActionResponse with the file download stream */ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) { validate(form, messages -> {}, () -> downloadpage(form.dictId)); verifyTokenKeep(() -> downloadpage(form.dictId)); return synonymService.getSynonymFile(form.dictId)Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 23.7K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/entity/FacetInfo.java
if (StringUtil.isNotBlank(fessConfig.getQueryFacetFields())) { field = StreamUtil.split(fessConfig.getQueryFacetFields(), ",") .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).distinct().toArray(n -> new String[n])); } if (StringUtil.isNotBlank(fessConfig.getQueryFacetFieldsSize())) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 5.3K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/Location.java
*/ int getColumnNumber(); /** * Return the byte or character offset into the input source this location * is pointing to. If the input source is a file or a byte stream then * this is the byte offset into that stream, but if the input source is * a character media then the offset is the character offset. * Returns -1 if there is no offset available. * @return the current offset */Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 1.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelper.java
if (StringUtil.isNotBlank(overrides)) { final Map<String, String> map = new LinkedHashMap<>(); StreamUtil.split(overrides, "\n").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(s -> { final String[] values = StringUtils.split(s, "=", 2); if (values.length == 2) { map.put(values[0].trim(), values[1].trim());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Jan 24 09:06:33 GMT 2026 - 2.7K bytes - Click Count (0)