- Sort Score
- Num 10 results
- Language All
Results 501 - 510 of 1,261 for Stream (0.21 seconds)
-
src/test/java/jcifs/EncodableTest.java
package jcifs; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertThrows; import java.util.Arrays; import java.util.stream.Stream; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments; import org.junit.jupiter.params.provider.MethodSource;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.6K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Splitter.java
@IgnoreJRERequirement public Stream<String> splitToStream(CharSequence sequence) { // Can't use Streams.stream() from base return StreamSupport.stream(split(sequence).spliterator(), false); } /** * Returns a {@code MapSplitter} which splits entries based on this splitter, and splits entries * into keys and values using the specified separator.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 23.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
null } } } /** * Returns a new unbuffered output stream to write the value at [index]. If the underlying * output stream encounters errors when writing to the filesystem, this edit will be aborted * when [commit] is called. The returned output stream does not throw IOExceptions. */ fun newSink(index: Int): Sink { synchronized(this@DiskLruCache) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 34.7K bytes - Click Count (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()) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Mar 15 08:03:27 GMT 2026 - 56.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/SmbBasicFileInfoTest.java
package jcifs.internal; import java.util.stream.Stream; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments; import org.junit.jupiter.params.provider.MethodSource; import org.mockito.Mockito; import org.mockito.junit.jupiter.MockitoExtension; /**
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.8K bytes - Click Count (0) -
docs/changelogs/changelog_3x.md
## Version 3.14.5 _2020-01-03_ * Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after a stream timeout to determine whether the connection should remain eligible for pooling. ## Version 3.14.4 _2019-09-29_Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Click Count (0) -
compat/maven-builder-support/src/main/java/org/apache/maven/building/StringSource.java
} @Override public String getLocation() { return location; } /** * Gets the content of this source. * * @return The underlying character stream, never {@code null}. */ public String getContent() { return content; } @Override public String toString() { return getLocation(); } @OverrideCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jan 15 18:51:29 GMT 2025 - 3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
* may never exhaust the source stream and therefore not complete the cached response. */ @Throws(IOException::class) private fun cacheWritingResponse( cacheRequest: CacheRequest?, response: Response, ): Response { // Some apps return a null body; for compatibility we treat that like a null cache request.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 10.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableAsList.java
} @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0; } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use SerializedForm"); } @GwtIncompatible @J2ktIncompatible @Override Object writeReplace() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 2.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java
*/ package org.codelibs.fess.helper; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.regex.Pattern; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.8K bytes - Click Count (0)