Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 1,019 for readFn (0.06 seconds)

  1. 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} for
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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} for
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top