- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,102 for Stream (0.04 sec)
-
src/main/java/org/codelibs/fess/auth/AuthenticationManager.java
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
* weight from the default (16) to a new value. * * @param streamId stream which has a priority change. * @param streamDependency the stream ID this stream is dependent on. * @param weight relative proportion of priority in `[1..256]`. * @param exclusive inserts this stream ID as the sole child of `streamDependency`. */ fun priority( streamId: Int,
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 19.8K bytes - Viewed (0) -
cmd/object-api-utils_test.go
metadata: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86", "x-amz-storage-class": "STANDARD"}, want: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86"}, }, { name: "2",
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 24.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java
return; } final Pair<String[], String[]> groupsAndRoles = getParentGroup(user, id, depth); StreamUtil.stream(groupsAndRoles.getFirst()).of(stream -> stream.forEach(groupList::add)); StreamUtil.stream(groupsAndRoles.getSecond()).of(stream -> stream.forEach(roleList::add)); if (logger.isDebugEnabled()) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 56.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/AbstractDataStore.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.ds; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 7.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbAuthExceptionTest.java
import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertSame; import static org.junit.jupiter.api.Assertions.assertTrue; 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;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.3K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlan.java
} public Stream<BuildStep> steps(MavenProject project) { return Optional.ofNullable(plan.get(project)) .map(m -> m.values().stream()) .orElse(Stream.empty()); } public Optional<BuildStep> step(MavenProject project, String name) { return Optional.ofNullable(plan.get(project)).map(m -> m.get(name)); }Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Mar 28 12:11:25 UTC 2025 - 6.1K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java
} } public void executeBefore(BuildStep stepToExecuteAfter) { stepToExecuteAfter.executeAfter(this); } public Stream<MojoExecution> executions() { return mojos.values().stream().flatMap(m -> m.values().stream()); } @Override public boolean equals(Object o) { if (this == o) { return true; }Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Apr 30 16:21:08 UTC 2025 - 4.9K bytes - Viewed (0) -
src/main/java/jcifs/SmbPipeHandle.java
/** * Gets the input stream for reading from this pipe. * * @return this pipe's input stream * @throws CIFSException if an error occurs getting the input stream */ InputStream getInput() throws CIFSException; /** * Gets the output stream for writing to this pipe. * * @return this pipe's output streamRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
* is deleted when the stream is closed. */ public class TemporaryFileInputStream extends InputStream { private final File tempFile; private final FileInputStream fileInputStream; /** * A class that provides an input stream for reading from a temporary file.Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 4.1K bytes - Viewed (0)