- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 989 for asStream (0.07 sec)
-
android/guava-tests/test/com/google/common/math/StatsTesting.java
BigInteger.valueOf(Long.MAX_VALUE) .multiply(BigInteger.valueOf(Long.MAX_VALUE)) .divide(BigInteger.valueOf(16L)) .doubleValue(); /** * Returns a stream of a million primitive doubles. The stream is parallel, which should cause * {@code collect} calls to run in multithreaded mode, so testing the combiner as well as the * supplier and accumulator. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 23.8K bytes - Viewed (0) -
buildscripts/upgrade-tests/nginx.conf
error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 1024; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"';Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Nov 21 18:41:30 UTC 2021 - 1.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PasswordBasedExtractor.java
import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.regex.Pattern; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.Pair;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 5.1K bytes - Viewed (0) -
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 20 18:31:45 UTC 2024 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/FessApiAction.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.api; import java.util.Locale; import java.util.stream.Collectors; import org.codelibs.fess.app.service.AccessTokenService; import org.codelibs.fess.app.web.api.ApiResult.ApiErrorResponse; import org.codelibs.fess.app.web.api.ApiResult.Status;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosApRequest.java
throw new PACDecodingException("Empty kerberos ApReq"); } ASN1Sequence sequence; try { try (ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token))) { sequence = ASN1Util.as(ASN1Sequence.class, stream); } } catch (IOException e) { throw new PACDecodingException("Malformed Kerberos Ticket", e); } return sequence;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeMultiset.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(elementSet().comparator()); Serialization.writeMultiset(this, stream); } @J2ktIncompatible @GwtIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); @SuppressWarnings("unchecked")
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 34.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
* * @return The created OpenSearch client. */ protected Client createClient() { final String[] hosts = split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n])); final Settings settings = Settings.builder().putList("http.hosts", hosts).build(); return new HttpClient(settings, null); }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 02:01:26 UTC 2025 - 26.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* @serialData the ConcurrentMap of elements and their counts. */ private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(countMap); } private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); @SuppressWarnings("unchecked") // reading data stored by writeObjectRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 22:42:14 UTC 2025 - 22.3K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleMappingDelegate.java
import javax.inject.Singleton; import java.util.ArrayList; import java.util.Comparator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.TreeMap; import java.util.stream.Collectors; import org.apache.maven.execution.MavenSession; import org.apache.maven.lifecycle.Lifecycle; import org.apache.maven.lifecycle.LifecycleMappingDelegate; import org.apache.maven.model.Plugin;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Dec 13 23:04:37 UTC 2024 - 8.5K bytes - Viewed (0)