- Sort Score
- Num 10 results
- Language All
Results 501 - 510 of 829 for readFn (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/post-policy_test.go
} writer.Write([]byte("hello world")) // Close before creating the new request. w.Close() // Set the body equal to the created policy. reader := bytes.NewReader(buf.Bytes()) req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader) if err != nil { return nil, err } // Set form content-type. req.Header.Set("Content-Type", w.FormDataContentType())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 30.6K bytes - Click Count (0) -
src/archive/tar/common.go
// other fields in Header take precedence over PAXRecords. PAXRecords map[string]string // Format specifies the format of the tar header. // // This is set by Reader.Next as a best-effort guess at the format. // Since the Reader liberally reads some non-compliant files, // it is possible for this to be FormatUnknown. // // If the format is unspecified when Writer.WriteHeader is called,
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 24.5K bytes - Click Count (0) -
api/go1.txt
pkg bufio, func NewWriter(io.Writer) *Writer pkg bufio, func NewWriterSize(io.Writer, int) *Writer pkg bufio, method (*Reader) Buffered() int pkg bufio, method (*Reader) Peek(int) ([]uint8, error) pkg bufio, method (*Reader) Read([]uint8) (int, error) pkg bufio, method (*Reader) ReadByte() (uint8, error) pkg bufio, method (*Reader) ReadBytes(uint8) ([]uint8, error)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbFileFilterTest.java
@Mock private SmbFile smbFile; // Provides file names and whether a simple name-based filter should accept them private static Stream<Arguments> nameCases() { return Stream.of(Arguments.of("readme.txt", true), Arguments.of("notes.log", false), Arguments.of("", false), Arguments.of(null, false)); } @Test @DisplayName("accept: returns true for directories; verifies isDirectory is invoked")Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.4K bytes - Click Count (0) -
api/maven-api-core/src/test/java/org/apache/maven/api/services/SourcesTest.java
verify(locator, never()).locateExistingPom(any(Path.class)); } @Test void testStreamReading() throws IOException { // Test stream reading functionality Path testFile = tempDir.resolve("test.txt"); String content = "test content"; Files.writeString(testFile, content); Source source = Sources.fromPath(testFile);
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Sep 29 14:45:25 GMT 2025 - 5.4K bytes - Click Count (0) -
src/cmd/asm/internal/lex/lex.go
log.Fatalf("%s\n", err) } input.Push(NewTokenizer(name, fd, fd)) return input } // The other files in this directory each contain an implementation of TokenReader. // A TokenReader is like a reader, but returns lex tokens of type Token. It also can tell you what // the text of the most recently returned token is, and where it was found. // The underlying scanner elides all spaces except newline, so the input looks like a stream of
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 4.1K bytes - Click Count (0) -
internal/config/config.go
// ContextKeyForTargetFromConfig - key for context for target from config const ContextKeyForTargetFromConfig = ContextKeyString("ContextKeyForTargetFromConfig") // ParseConfigTargetID - read all targetIDs from reader func ParseConfigTargetID(r io.Reader) (ids map[string]bool, err error) { ids = make(map[string]bool) scanner := bufio.NewScanner(r) for scanner.Scan() { // Skip any empty lines, or comment like characters
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 37.7K bytes - Click Count (0) -
docs/sts/ldap.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file %s: %v", sessionPolicyFile, err) } else { bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } ldapOpts = append(ldapOpts, cr.LDAPIdentityPolicyOpt(policy)) } if expiryDuration != 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Aug 07 12:59:47 GMT 2024 - 4K bytes - Click Count (0) -
impl/maven-core/src/test/remote-repo/org/apache/maven/its/plugins/maven-it-plugin/0.1/maven-it-plugin-0.1.jar
false false false true process-test-classes org.apache.maven.plugin.coreit.EMojo java per-lookup once-per-session it Does nothing. compile false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session xpp3-reader Does nothing. false true false false false true generate-sources org.apache.maven.plugin.coreit.CMojo java per-lookup once-per-session models java.lang.String[] false true version java.lang.String false true ${version} xpp3-writer Does nothing. false...
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 13.2K bytes - Click Count (0) -
src/archive/zip/struct.go
// Copyright 2010 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. /* Package zip provides support for reading and writing ZIP archives. See the [ZIP specification] for details. This package does not support disk spanning. A note about ZIP64: To be backwards compatible the FileHeader has both 32 and 64 bit Size
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue May 28 21:41:09 GMT 2024 - 12.1K bytes - Click Count (0)