- Sort Score
- Num 10 results
- Language All
Results 401 - 410 of 722 for Write (0.02 seconds)
-
guava-tests/test/com/google/common/io/ByteSinkTester.java
ByteStreams.copy(new ByteArrayInputStream(data), out); } finally { out.close(); } assertContainsExpectedBytes(); } public void testWrite() throws IOException { sink.write(data); assertContainsExpectedBytes(); } public void testWriteFrom_inputStream() throws IOException { sink.writeFrom(new ByteArrayInputStream(data)); assertContainsExpectedBytes();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 4K bytes - Click Count (0) -
docs/en/docs/advanced/openapi-webhooks.md
All the **logic** about how to register the URLs for webhooks and the code to actually send those requests is up to you. You write it however you want to in **your own code**. ## Documenting webhooks with **FastAPI** and OpenAPI { #documenting-webhooks-with-fastapi-and-openapi }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 2.9K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java
try (OutputStream out = Files.newOutputStream(metadataFile.toPath())) { new MetadataStaxWriter().write(out, metadata.getDelegate()); } catch (IOException | XMLStreamException e) { String msg = "Could not write fixed metadata to " + metadataFile + ": " + e.getMessage(); if (getLogger().isDebugEnabled()) { getLogger().warn(msg, e);Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 18.9K bytes - Click Count (0) -
cmd/object-lambda-handlers_test.go
w.Header().Set(xhttp.AmzRequestToken, functionToken) w.Header().Set(xhttp.AmzFwdHeaderContentType, contentType) w.Header().Set(xhttp.AmzFwdStatus, strconv.Itoa(lambdaStatus)) w.WriteHeader(lambdaStatus) w.Write([]byte(lambdaBody)) })) defer lambdaServer.Close() lambdaARN := "arn:minio:s3-object-lambda::lambda1:webhook" cfg := config.New() cfg[config.LambdaWebhookSubSys] = map[string]config.KVS{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 18 21:56:31 GMT 2025 - 5.2K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/transforms/Minify.kt
visitTree(classDetails, classesDir, jarOutputStream, visited) } } } catch (exception: Exception) { throw ClassAnalysisException("Could not write shaded Jar $jarFile", exception) } } private fun visitTree( classDetails: ClassDetails, classesDir: File, jarOutputStream: JarOutputStream,
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Dec 18 11:46:45 GMT 2025 - 4.9K bytes - Click Count (0) -
build-logic-commons/basics/src/test/kotlin/gradlebuild/basics/tasks/PackageListGeneratorIntegrationTest.kt
} private fun touchFile(path: Path) { Files.createDirectories(path.parent) Files.write(path, byteArrayOf()) } private fun someClasses(): Sequence<Path> { val directory = projectDir.resolve("classes") touchFile(directory.resolve("com/acme/Foo.class"))Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Mar 25 08:50:34 GMT 2025 - 5.1K bytes - Click Count (0) -
internal/s3select/json/record.go
} w := csv.NewWriter(writer) w.Comma = opts.FieldDelimiter w.Quote = opts.Quote w.AlwaysQuote = opts.AlwaysQuote w.QuoteEscape = opts.QuoteEscape if err := w.Write(csvRecord); err != nil { return err } w.Flush() return w.Error() } // Raw - returns the underlying representation. func (r *Record) Raw() (sql.SelectObjectFormat, any) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/etag/etag.go
func Multipart(etags ...ETag) ETag { if len(etags) == 0 { return nil } var n int64 h := md5.New() for _, etag := range etags { if !etag.IsMultipart() && !etag.IsEncrypted() { h.Write(etag) n++ } } etag := append(h.Sum(nil), '-') return strconv.AppendInt(etag, n, 10) } // Set adds the ETag to the HTTP headers. It overwrites any // existing ETag entry. //
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 13.2K bytes - Click Count (0) -
internal/config/identity/openid/openid.go
} // We set the resource ID of the role arn as a hash of client // ID, so we can get a short roleARN that stays the same on // restart. var resourceID string { h := sha1.New() h.Write([]byte(p.ClientID)) bs := h.Sum(nil) resourceID = base64.RawURLEncoding.EncodeToString(bs) } p.roleArn, err = arn.NewIAMRoleARN(resourceID, serverRegion) if err != nil {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 17.3K bytes - Click Count (0) -
internal/jwt/parser.go
return jwtgo.ErrSignatureInvalid } n, err := base64DecodeBytes(token[i+1:], *bufp) if err != nil { return err } borrow := signer.HashBorrower() hasher := hmac.New(borrow.Borrow, key) hasher.Write(token[:i]) if !hmac.Equal((*bufp)[:n], hasher.Sum(nil)) { borrow.ReturnAll() return jwtgo.ErrSignatureInvalid } borrow.ReturnAll() if claims.AccessKey == "" && claims.Subject == "" {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.1K bytes - Click Count (0)