- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 1,019 for readFn (0.06 seconds)
-
guava/src/com/google/common/io/Files.java
@GwtIncompatible public final class Files { private Files() {} /** * Returns a buffered reader that reads from a file using the given character set. * * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}. * * @param file the file to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} forCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 25 20:24:13 GMT 2025 - 32.8K bytes - Click Count (0) -
internal/ioutil/ioutil.go
for s.skipCount > 0 { if l > s.skipCount { l = s.skipCount } n, err := s.Reader.Read(tmp[:l]) if err != nil { return 0, err } s.skipCount -= int64(n) } } return s.Reader.Read(p) } // NewSkipReader - creates a SkipReader func NewSkipReader(r io.Reader, n int64) io.Reader { return &SkipReader{r, n} }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
cmd/sftp-server-driver.go
} func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) { // This is not timing the actual read operation, but the time it takes to prepare the reader. stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(0, err) flags := r.Pflags() if !flags.Read { // sanity check return nil, os.ErrInvalid } bucket, object := path2BucketObject(r.Filepath) if bucket == "" {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Feb 10 16:35:49 GMT 2025 - 11.6K bytes - Click Count (0) -
internal/bucket/object/lock/lock.go
// Maximum 4KiB size per object lock config. const maxObjectLockConfigSize = 1 << 12 // ParseObjectLockConfig parses ObjectLockConfig from xml func ParseObjectLockConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil { return nil, err } return &config, nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.9K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
@GwtIncompatible public final class Files { private Files() {} /** * Returns a buffered reader that reads from a file using the given character set. * * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}. * * @param file the file to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} forCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 25 20:24:13 GMT 2025 - 32.8K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/configuration/SettingsXmlConfigurationProcessor.java
request.getEventSpyDispatcher().onEvent(settingsRequest); } LOGGER.debug( "Reading installation settings from '{}'", getLocation(settingsRequest.getGlobalSettingsSource(), settingsRequest.getGlobalSettingsFile())); LOGGER.debug( "Reading project settings from '{}'",
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 19 18:49:57 GMT 2025 - 12K bytes - Click Count (0) -
api/go1.15.txt
pkg bufio, var ErrBadReadCount error pkg crypto, method (Hash) String() string pkg crypto/ecdsa, func SignASN1(io.Reader, *PrivateKey, []uint8) ([]uint8, error) pkg crypto/ecdsa, func VerifyASN1(*PublicKey, []uint8, []uint8) bool pkg crypto/ecdsa, method (*PrivateKey) Equal(crypto.PrivateKey) bool pkg crypto/ecdsa, method (*PublicKey) Equal(crypto.PublicKey) bool pkg crypto/ed25519, method (PrivateKey) Equal(crypto.PrivateKey) bool
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Jul 17 02:15:01 GMT 2020 - 7.6K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops_gen.go
return } case "PoolIndex": z.PoolIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "PoolIndex") return } case "SetIndex": z.SetIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "SetIndex") return } case "DiskIndex": z.DiskIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "DiskIndex") return
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 24.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java
* * @return a SuggestItem representing this ElevateWord */ public SuggestItem toSuggestItem() { final String[][] readingArray = this.getReadings().stream().map(reading -> new String[] { reading }).toArray(count -> new String[count][]); return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Fri Jul 04 14:00:23 GMT 2025 - 4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/MavenParser.java
"Failed to parse arguments from file (" + atFile + "): " + e.getMessage(), e.getCause()); } catch (IOException e) { throw new IllegalStateException("Error reading config file: " + atFile, e); } } protected MavenOptions parseMavenConfigOptions(Path configFile) { try (Stream<String> lines = Files.lines(configFile, StandardCharsets.UTF_8)) {
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Oct 14 12:35:44 GMT 2025 - 4.4K bytes - Click Count (0)