Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 300 for reader_r (0.1 sec)

  1. internal/bucket/versioning/versioning.go

    func (v Versioning) PrefixesExcluded() bool {
    	return len(v.ExcludedPrefixes) > 0 || v.ExcludeFolders
    }
    
    // ParseConfig - parses data in given reader to VersioningConfiguration.
    func ParseConfig(reader io.Reader) (*Versioning, error) {
    	var v Versioning
    	if err := xml.NewDecoder(reader).Decode(&v); err != nil {
    		return nil, err
    	}
    	if err := v.Validate(); err != nil {
    		return nil, err
    	}
    	return &v, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/core/io/LineIteratorTest.java

     */
    public class LineIteratorTest {
    
        /**
         * @throws Exception
         */
        @Test
        public void test() throws Exception {
            final StringReader reader = new StringReader("aaa\nbbb\nccc\n");
            final LineIterator it = new LineIterator(reader);
            assertThat(it.hasNext(), is(true));
            assertThat(it.next(), is("aaa"));
            assertThat(it.hasNext(), is(true));
            assertThat(it.next(), is("bbb"));
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

       * to determine the charset of the response bytes.
       *
       * Otherwise the response bytes are decoded as UTF-8.
       */
      fun charStream(): Reader =
        reader ?: BomAwareReader(source(), charset()).also {
          reader = it
        }
    
      /**
       * Returns the response as a string.
       *
       * If the response starts with a
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/DefaultMetadataReader.java

            return read(Files.newInputStream(input.toPath()), options);
        }
    
        public Metadata read(Reader input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (Reader in = input) {
                return new Metadata(new MetadataStaxReader().read(in, isStrict(options)));
            } catch (XMLStreamException e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. docs/debugging/inspect/export.go

    		return buf.Bytes(), nil
    	}
    
    	fmt.Println("{")
    
    	hasWritten := false
    	var r io.Reader
    	var sz int64
    	f, e := os.Open(downloadPath)
    	if e != nil {
    		return e
    	}
    	if st, e := f.Stat(); e == nil {
    		sz = st.Size()
    	}
    	defer f.Close()
    	r = f
    
    	zr, e := zip.NewReader(r.(io.ReaderAt), sz)
    	if e != nil {
    		return e
    	}
    	for _, file := range zr.File {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  6. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        val connection = url.openConnection() as HttpURLConnection
        connection.setRequestProperty("Accept-Language", "en-US")
        val reader = BufferedReader(InputStreamReader(connection.inputStream, UTF_8))
        assertThat(connection.responseCode).isEqualTo(HttpURLConnection.HTTP_OK)
        assertThat(reader.readLine()).isEqualTo("hello world")
        val request = server.takeRequest()
        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_experimental_reader.h

    // streamz->GetCell("label-value")->IncrementBy(1);
    //
    // The test code can then read and test the value of that counter:
    //
    // auto* reader = TFE_MonitoringNewCounterReader("name");
    // test();
    // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value");
    
    // Opaque handle to a reader.
    typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader;
    
    // Returns a handle to be used for reading values from streamz counter. The
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java

                        e.getLocation().getColumnNumber(),
                        e);
            }
        }
    
        @Override
        public Settings read(Reader input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (Reader in = input) {
                InputSource source = (InputSource) options.get(InputSource.class.getName());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. internal/hash/reader_test.go

    	}
    }
    
    // Tests hash reader checksum verification.
    func TestHashReaderVerification(t *testing.T) {
    	testCases := []struct {
    		desc              string
    		src               io.Reader
    		size              int64
    		actualSize        int64
    		md5hex, sha256hex string
    		err               error
    	}{
    		0: {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  10. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        connection.setRequestProperty("Accept-Language", "en-US")
        val inputStream = connection.inputStream
        val reader = BufferedReader(InputStreamReader(inputStream, StandardCharsets.UTF_8))
        assertThat(connection.getResponseCode()).isEqualTo(HttpURLConnection.HTTP_OK)
        assertThat(reader.readLine()).isEqualTo("hello world")
        val request = server.takeRequest()
        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top