Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,189 for Reader (0.08 sec)

  1. guava-tests/test/com/google/common/io/LineBufferTest.java

      }
    
      // Returns a Readable that is *not* a Reader.
      private static Readable getChunkedReadable(String input, int chunk) {
        Reader reader = getChunkedReader(input, chunk);
        return new Readable() {
          @Override
          public int read(CharBuffer cbuf) throws IOException {
            return reader.read(cbuf);
          }
        };
      }
    
      private static Reader getChunkedReader(String input, int chunk) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  2. cmd/update.go

    	return resp.Body, nil
    }
    
    var updateInProgress atomic.Uint32
    
    // Function to get the reader from an architecture
    func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) {
    	transport := getUpdateTransport(30 * time.Second)
    	var reader io.ReadCloser
    	if u.Scheme == "https" || u.Scheme == "http" {
    		reader, err = getUpdateReaderFromURL(u, transport, mode)
    		if err != nil {
    			return nil, nil, err
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/BaseEncodingTest.java

            // of
            // InputStream.read(byte[], int, int)
            // See https://github.com/google/guava/issues/3542
            Reader reader = new StringReader(cannotDecode);
            InputStream decodingStream = encoding.decodingStream(reader);
            try {
              ByteStreams.exhaust(decodingStream);
              fail("Expected DecodingException");
            } catch (DecodingException expected) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 24.7K bytes
    - Viewed (0)
  4. 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
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Jul 17 02:15:01 UTC 2020
    - 7.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharSourceTest.java

        BufferedReader reader = source.openBufferedStream();
        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  6. cmd/perf-tests.go

    		RXTotalDuration: delta,
    		Error:           errStr,
    		TotalConn:       uint64(connectionsPerPeer),
    	}
    }
    
    // perfNetRequest - reader for http.request.body
    func perfNetRequest(ctx context.Context, deploymentID, reqPath string, reader io.Reader) (result madmin.SiteNetPerfNodeResult) {
    	result = madmin.SiteNetPerfNodeResult{}
    	cli, err := globalSiteReplicationSys.getAdminClient(ctx, deploymentID)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/opensearch/extension/analysis/ProlongedSoundMarkCharFilterFactory.java

            if (value == null || value.length() == 0) {
                replacement = '\u30fc';
            } else {
                replacement = value.charAt(0);
            }
        }
    
        @Override
        public Reader create(final Reader tokenStream) {
            return new ProlongedSoundMarkCharFilter(tokenStream, replacement);
        }
    
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sat Mar 15 06:51:20 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/badword/ApiAdminBadwordAction.java

            validateApi(body, messages -> {});
            CommonPoolUtil.execute(() -> {
                try (Reader reader = new BufferedReader(new InputStreamReader(body.badWordFile.getInputStream(), getCsvEncoding()))) {
                    badWordService.importCsv(reader);
                    suggestHelper.storeAllBadWords(false);
                } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/CharSinkTest.java

        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
        assertEquals(STRING, sink.getString());
      }
    
      public void testWriteFrom_reader() throws IOException {
        StringReader reader = new StringReader(STRING);
        sink.writeFrom(reader);
    
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
        assertEquals(STRING, sink.getString());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt

        body.writeTo(bodyContent)
    
        val reader = MultipartReader(bodyContent, "boundary")
    
        val quickPart = reader.nextPart()!!
        assertThat(quickPart.headers).isEqualTo(
          headersOf(
            "Content-Type",
            "text/plain; charset=utf-8",
          ),
        )
        assertThat(quickPart.body.readUtf8()).isEqualTo("Quick")
    
        val brownPart = reader.nextPart()!!
        assertThat(brownPart.headers).isEqualTo(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 15.4K bytes
    - Viewed (0)
Back to top