- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for STREAM (0.4 sec)
-
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
TestFile gradleUserHomeOutputDir(String from, String to, Closure<String> stream = { output }) { outputDir(from, to, this.&gradleUserHomeOutputDirs, stream) } Set<TestFile> allOutputDirs(String from, String to, Closure<String> stream = { output }) { return projectOutputDirs(from, to, stream) + gradleUserHomeOutputDirs(from, to, stream) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0) -
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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
*/ public String toString() { return "PatternSet [" + "includes: {" + getIncludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}, " + "excludes: {" + getExcludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}]"; } ]]> </code> </codeSegment> </codeSegments> </class>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Apr 23 13:29:46 UTC 2024 - 115.1K bytes - Viewed (0) -
fastapi/applications.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 00:48:03 UTC 2024 - 172.2K bytes - Viewed (0) -
cmd/object-handlers.go
case authTypeStreamingSigned, authTypeStreamingSignedTrailer: // Initialize stream signature verifier. rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer) if s3Err != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL) return } case authTypeStreamingUnsignedTrailer: // Initialize stream chunked reader with optional trailers.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Maps.java
import java.util.SortedSet; import java.util.TreeMap; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.function.BinaryOperator; import java.util.stream.Collector; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.NonNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 159.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/Maps.java
import java.util.concurrent.ConcurrentMap; import java.util.function.BiConsumer; import java.util.function.BiFunction; import java.util.function.BinaryOperator; import java.util.function.Consumer; import java.util.stream.Collector; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.NonNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 24 19:38:27 UTC 2024 - 165.9K bytes - Viewed (0) -
src/net/http/transport_test.go
// requests don't race with the call to SetRSTAvoidanceDelay for a retry. defer cst.close() ts := cst.ts c := ts.Client() res, err := c.Post(ts.URL, "application/octet-stream", neverEnding('a')) if err != nil { return fmt.Errorf("Post: %v", err) } got, err := io.ReadAll(res.Body) if err != nil { return fmt.Errorf("Body ReadAll: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/http/serve_test.go
} r, err = c.Do(req) if err == nil { r.Body.Close() return fmt.Errorf("Get #2 expected error, got nil") } if mode == http2Mode { expected := "stream ID 3; INTERNAL_ERROR" // client IDs are odd, second stream should be 3 if !strings.Contains(err.Error(), expected) { return fmt.Errorf("http2 Get #2: expected error to contain %q, got %q", expected, err) } } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/asm9.go
case 43: /* data cache instructions: op (Ra+[Rb]), [th|l] */ /* TH field for dcbt/dcbtst: */ /* 0 = Block access - program will soon access EA. */ /* 8-15 = Stream access - sequence of access (data stream). See section 4.3.2 of the ISA for details. */ /* 16 = Block access - program will soon make a transient access to EA. */ /* 17 = Block access - program will not access EA for a long time. */
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 13:55:28 UTC 2024 - 156.1K bytes - Viewed (0)