- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for stream (0.18 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // DATA peer.acceptFrame() // DATA with FLAG_FIN peer.acceptFrame() // RST_STREAM peer.play() // Play it back. val connection = connect(peer) val stream = connection.newStream(headerEntries("a", "android"), true) val source = stream.getSource() val out = stream.getSink().buffer() source.close() assertFailsWith<IOException> {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 85K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 65.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(factory); stream.writeObject(backingMap()); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 86.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
if (results.stream() .flatMap(r -> r.getProblems().stream()) .anyMatch(p -> p.getSeverity() != org.apache.maven.model.building.ModelProblem.Severity.WARNING)) { org.apache.maven.model.building.ModelProblem cycle = results.stream() .flatMap(r -> r.getProblems().stream())
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 55.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
stream(parameter.getSuggestFields()).of(stream -> stream.forEach(builder::addField)); roleQueryHelper.build(SearchRequestType.SUGGEST).stream().forEach(builder::addRole); builder.setSize(parameter.getNum()); stream(langs).of(stream -> stream.forEach(builder::addLang)); stream(parameter.getTags()).of(stream -> stream.forEach(builder::addTag));
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 02:17:23 GMT 2024 - 50.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
server.enqueue( MockResponse(socketPolicy = ResetStreamAtStart(ErrorCode.REFUSED_STREAM.httpCode)), ) server.enqueue( MockResponse(socketPolicy = ResetStreamAtStart(ErrorCode.REFUSED_STREAM.httpCode)), ) server.enqueue( MockResponse(socketPolicy = ResetStreamAtStart(ErrorCode.REFUSED_STREAM.httpCode)), ) val request = Request(server.url("/"))
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/testdata/config_dump.json
Json - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 54.8K bytes - Viewed (1) -
cmd/admin-handlers.go
if publicKey != nil { w.WriteHeader(200) stream := estream.NewWriter(w) defer stream.Close() clusterKey, err := bytesToPublicKey(getSubnetAdminPublicKey()) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return } err = stream.AddKeyEncrypted(clusterKey) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2)