- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 348 for readArg (0.25 sec)
-
internal/ioutil/ioutil.go
return s.Reader.Read(p) } // NewSkipReader - creates a SkipReader func NewSkipReader(r io.Reader, n int64) io.Reader { return &SkipReader{r, n} } var copyBufPool = sync.Pool{ New: func() interface{} { b := make([]byte, 32*1024) return &b }, } // Copy is exactly like io.Copy but with reusable buffers. func Copy(dst io.Writer, src io.Reader) (written int64, err error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
src/os/readfrom_linux_test.go
}) } func testSpliceFile(t *testing.T, proto string, size, limit int64) { dst, src, data, hook, cleanup := newSpliceFileTest(t, proto, size) defer cleanup() // If we have a limit, wrap the reader. var ( r io.Reader lr *io.LimitedReader ) if limit >= 0 { lr = &io.LimitedReader{N: limit, R: src} r = lr if limit < int64(len(data)) { data = data[:limit] } } else { r = src
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/net/http/fs.go
list, err = d.ReadDir(-1) dirs = list } else { var list fileInfoDirs list, err = f.Readdir(-1) dirs = list } if err != nil { logf(r, "http: error reading directory: %v", err) Error(w, "Error reading directory", StatusInternalServerError) return } sort.Slice(dirs, func(i, j int) bool { return dirs.name(i) < dirs.name(j) }) w.Header().Set("Content-Type", "text/html; charset=utf-8")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 09 17:06:47 UTC 2024 - 31.1K bytes - Viewed (0) -
src/os/file.go
} if log := testlog.Logger(); log != nil { wd, err := Getwd() if err == nil { log.Chdir(wd) } } return nil } // Open opens the named file for reading. If successful, methods on // the returned file can be used for reading; the associated file // descriptor has mode O_RDONLY. // If there is an error, it will be of type *PathError. func Open(name string) (*File, error) { return OpenFile(name, O_RDONLY, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/BaseEncoding.java
} /** * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors. */ @J2ktIncompatible @GwtIncompatible // Reader,InputStream public abstract InputStream decodingStream(Reader reader); /** * Returns a {@code ByteSource} that reads base-encoded bytes from the specified {@code
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Mar 15 16:33:32 UTC 2024 - 41.7K bytes - Viewed (0) -
src/net/net.go
return err == context.DeadlineExceeded } // DNSConfigError represents an error reading the machine's DNS configuration. // (No longer used; kept for compatibility.) type DNSConfigError struct { Err error } func (e *DNSConfigError) Unwrap() error { return e.Err } func (e *DNSConfigError) Error() string { return "error reading DNS config: " + e.Err.Error() } func (e *DNSConfigError) Timeout() bool { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java
}, this::asEditHtml); } if (form.segmentation != null && form.reading != null && form.segmentation.split(" ").length != form.reading.split(" ").length) { throwValidationError(messages -> { messages.addErrorsInvalidKuromojiSegmentation("segmentation", form.segmentation, form.reading); }, this::asEditHtml); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 18.8K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
func (p *xlStorageDiskIDCheck) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) (err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCreateFile, volume, path) if err != nil { return err } defer done(size, &err) return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/configurationcache/ConfigurationCacheProblemsFixture.groovy
new JsonSlurper().parseText(jsonText) as Map<String, Object> } private static String linesBetween(File file, String beginLine, String endLine) { return file.withReader('utf-8') { reader -> reader.lines().iterator() .dropWhile { it != beginLine } .drop(1) .takeWhile { it != endLine } .collect() .join('\n') }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.8K bytes - Viewed (0) -
guava/src/com/google/common/io/BaseEncoding.java
} /** * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors. */ @J2ktIncompatible @GwtIncompatible // Reader,InputStream public abstract InputStream decodingStream(Reader reader); /** * Returns a {@code ByteSource} that reads base-encoded bytes from the specified {@code
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Mar 15 16:33:32 UTC 2024 - 41.7K bytes - Viewed (0)