- Sort Score
- Num 10 results
- Language All
Results 281 - 290 of 1,264 for Streams (0.14 seconds)
-
android/guava/src/com/google/common/collect/EnumBiMap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); stream.writeObject(valueTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading fields populated by writeObject
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 6.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/EnumBiMap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); stream.writeObject(valueTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading fields populated by writeObject
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 6.2K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/ForbiddenPatternsTask.java
import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.IntStream; import java.util.stream.Stream; /** * Checks for patterns in source files for the project which are forbidden. */ public abstract class ForbiddenPatternsTask extends DefaultTask { /*Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 6.8K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/UpgradePropertiesRuleSetup.java
import java.util.AbstractMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; import static gradlebuild.binarycompatibility.upgrades.UpgradedProperties.CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES;
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Aug 19 15:30:48 GMT 2024 - 4.5K bytes - Click Count (0) -
internal/s3select/jstream/decoder_test.go
var ( counter int mv *MetaValue body = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]` ) decoder := NewDecoder(mkReader(body), 1) for mv = range decoder.Stream() { counter++ t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value) } if err := decoder.Err(); err != nil { t.Fatalf("decoder error: %s", err) } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt
/** Returns the trailers after the HTTP response if they're ready. May be empty. */ @Throws(IOException::class) fun peekTrailers(): Headers? /** * Cancel this stream. Resources held by this stream will be cleaned up, though not synchronously. * That may happen later by the connection pool thread. */ fun cancel() /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 3.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/ImmutableBiMapFloodingTest.java
import java.util.Map; import java.util.Map.Entry; import java.util.stream.Stream; import org.jspecify.annotations.NullUnmarked; @GwtIncompatible @NullUnmarked public class ImmutableBiMapFloodingTest extends AbstractHashFloodingTest<BiMap<Object, Object>> { public ImmutableBiMapFloodingTest() { super( EnumSet.allOf(ConstructionPathway.class).stream() .flatMap( path ->
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jul 28 19:11:14 GMT 2025 - 4.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/util/PrunedTag.java
*/ package org.codelibs.fess.util; import static org.codelibs.core.stream.StreamUtil.split; import java.util.Objects; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.commons.lang3.StringUtils; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.stream.StreamUtil; import org.codelibs.fess.exception.FessSystemException; import org.w3c.dom.Node; /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Nov 24 04:23:08 GMT 2025 - 7.1K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/relocation/UserPropertiesArtifactRelocationSource.java
import javax.inject.Named; import javax.inject.Singleton; import java.util.Arrays; import java.util.List; import java.util.Objects; import java.util.function.Predicate; import java.util.stream.Collectors; import java.util.stream.Stream; import org.apache.maven.model.Model; import org.apache.maven.repository.internal.MavenArtifactRelocationSource; import org.apache.maven.repository.internal.RelocatedArtifact;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/service/AccessTokenService.java
} stream(accessToken.getPermissions()).of(stream -> stream.forEach(permissionSet::add)); final String name = accessToken.getParameterName(); stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add)); return OptionalEntity.of(permissionSet);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 5.5K bytes - Click Count (0)