Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,189 for Reader (0.04 sec)

  1. src/test/java/org/codelibs/core/io/PropertiesUtilTest.java

        /**
         * Test method for
         * {@link org.codelibs.core.io.PropertiesUtil#load(java.util.Properties, java.io.Reader)}
         * .
         */
        @Test
        public void testLoadPropertiesReaderReaderNull() {
            exception.expect(NullArgumentException.class);
            exception.expectMessage(is("[ECL0008]argument[reader] is null."));
            final InputStreamReader inputStreamReader = null;
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

     * String indexName = "your_index_name";
     *
     * ESSourceReader reader = new ESSourceReader(client, settings, indexName);
     * reader.setScrollSize(1000); // Set the scroll size
     * reader.setLimitOfDocumentSize(1024 * 1024); // Limit document size to 1MB
     * reader.setQuery(QueryBuilders.termQuery("field", "value")); // Set a query
     *
     * Map<String, Object> document;
     * while ((document = reader.read()) != null) {
     *     // Process the document
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 11K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/sereq/AdminSereqAction.java

         * Creates a CURL request from the provided header string.
         *
         * @param header the header string containing HTTP method and path
         * @return CURL request object or null if header is invalid
         */
        private CurlRequest getCurlRequest(final String header) {
            if (StringUtil.isBlank(header)) {
                return null;
            }
    
            final String[] values = header.split(" ");
            if (values.length != 2) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  4. 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 Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  5. cmd/admin-bucket-handlers.go

    	defer zipWriter.Close()
    
    	rawDataFn := func(r io.Reader, filename string, sz int) {
    		header, zerr := zip.FileInfoHeader(dummyFileInfo{
    			name:    filename,
    			size:    int64(sz),
    			mode:    0o600,
    			modTime: time.Now(),
    			isDir:   false,
    			sys:     nil,
    		})
    		if zerr == nil {
    			header.Method = zip.Deflate
    			zwriter, zerr := zipWriter.CreateHeader(header)
    			if zerr == nil {
    				io.Copy(zwriter, r)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  6. api/go1.17.txt

    pkg archive/zip, method (*File) OpenRaw() (io.Reader, error)
    pkg archive/zip, method (*Writer) Copy(*File) error
    pkg archive/zip, method (*Writer) CreateRaw(*FileHeader) (io.Writer, error)
    pkg compress/lzw, method (*Reader) Close() error
    pkg compress/lzw, method (*Reader) Read([]uint8) (int, error)
    pkg compress/lzw, method (*Reader) Reset(io.Reader, Order, int)
    pkg compress/lzw, method (*Writer) Close() error
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 18K bytes
    - Viewed (0)
  7. cmd/batch-job-common-types_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobKV) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 21.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/CharSourceTester.java

      }
    
      public void testOpenStream() throws IOException {
        Reader reader = source.openStream();
    
        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();
    
        assertExpectedString(writer.toString());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/SourceSinkFactories.java

        }
    
        @Override
        public String getSinkContents() throws IOException {
          Path file = getPath();
          try (Reader reader = java.nio.file.Files.newBufferedReader(file, UTF_8)) {
            StringBuilder builder = new StringBuilder();
            for (int c = reader.read(); c != -1; c = reader.read()) {
              builder.append((char) c);
            }
            return builder.toString();
          }
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

            if (truncated) {
              socket.close()
            }
          } else {
            // read a frame
            val inFrame = InFrame(i, reader)
            reader.nextFrame(false, inFrame)
            inFrames.add(inFrame)
          }
        }
      }
    
      fun openSocket(): Socket = Socket("localhost", port)
    
      @Synchronized override fun close() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top