Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 891 for readAs (0.12 seconds)

  1. compat/maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Reader.java

        }
    
        /**
         * Method read.
         *
         * @param reader a reader object.
         * @param strict a strict object.
         * @return Metadata
         * @throws IOException            IOException if any.
         * @throws XmlPullParserException XmlPullParserException if
         *                                any.
         */
        public Metadata read(Reader reader, boolean strict) throws IOException, XmlPullParserException {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb/SmbFileInputStream.java

        }
    
        /**
         * Reads up to b.length bytes of data from this input stream into an array of bytes.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public int read(final byte[] b) throws IOException {
            return read(b, 0, b.length);
        }
    
        /**
         * Reads up to len bytes of data from this input stream into an array of bytes.
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/hash/HashingInputStream.java

        if (b != -1) {
          hasher.putByte((byte) b);
        }
        return b;
      }
    
      /**
       * Reads the specified bytes of data from the underlying input stream and updates the hasher with
       * the bytes read.
       */
      @Override
      @CanIgnoreReturnValue
      public int read(byte[] bytes, int off, int len) throws IOException {
        int numOfBytesRead = in.read(bytes, off, len);
        if (numOfBytesRead != -1) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  4. cmd/post-policy-fan-out.go

    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				reader, err = reader.WithEncryption(hr, &objectEncryptionKey)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    			}
    
    			objInfo, err := objectAPI.PutObject(ctx, bucket, req.Key, reader, ObjectOptions{
    				Versioned:        globalBucketVersioningSys.PrefixEnabled(bucket, req.Key),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/opensearch/extension/analysis/NumberConcatenationFilterFactory.java

                final File suffixWordsFile = environment.configDir().resolve(suffixWordsPath).toFile();
                try (Reader reader = IOUtils.getDecodingReader(new FileInputStream(suffixWordsFile), StandardCharsets.UTF_8)) {
                    suffixWords = WordlistLoader.getWordSet(reader);
                } catch (final IOException e) {
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun May 18 02:59:16 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. cmd/erasure-sets.go

    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  7. src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java

            }
        }
    
        private Reader getReader(final boolean reload) throws IOException {
            if (reload) {
                if (reloadableFile == null) {
                    throw new IllegalArgumentException("reloadableFile is null.");
                }
                return new InputStreamReader(new FileInputStream(reloadableFile), StandardCharsets.UTF_8);
            }
    
            Reader reader = null;
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun May 18 02:59:16 GMT 2025
    - 6.7K bytes
    - Click Count (1)
  8. src/cmd/addr2line/main.go

    // license that can be found in the LICENSE file.
    
    // Addr2line is a minimal simulation of the GNU addr2line tool,
    // just enough to support pprof.
    //
    // Usage:
    //
    //	go tool addr2line binary
    //
    // Addr2line reads hexadecimal addresses, one per line and with optional 0x prefix,
    // from standard input. For each input address, addr2line prints two output lines,
    // first the name of the function containing the address and second the file:line
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Jun 21 19:58:04 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  9. internal/s3select/select.go

    		return rsc.offset, errors.New("seek past end of object")
    	}
    	if rsc.reader != nil {
    		_ = rsc.reader.Close()
    		rsc.reader = nil
    	}
    	return rsc.offset, nil
    }
    
    // Read call to implement io.Reader
    func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) {
    	if rsc.reader == nil {
    		rsc.reader, err = rsc.segmentReader(rsc.offset)
    		if err != nil {
    			return 0, err
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  10. tensorflow/c/eager/c_api_experimental_reader_test.cc

      auto* reader = TFE_MonitoringNewCounterReader(counter_name);
      IncrementCounter0(counter);
    
      int64_t actual = TFE_MonitoringReadCounter0(reader);
    
      CHECK_EQ(actual, 1);
    }
    
    TEST(CAPI, MonitoringCellReader1) {
      auto counter_name = "test/counter1";
      auto label_name = "test/label";
      auto* counter = CreateCounter1(counter_name, label_name);
      auto* reader = TFE_MonitoringNewCounterReader(counter_name);
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 20 03:14:47 GMT 2023
    - 2.9K bytes
    - Click Count (0)
Back to Top