Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 431 - 440 of 1,047 for readFn (0.23 seconds)

  1. test_docs.sh

    # Generate the API docs
    ./gradlew dokkaGeneratePublicationHtml -PokhttpDokka=true
    
    mv ./build/dokka/html docs/5.x
    
    # Copy in special files that GitHub wants in the project root.
    cat README.md | grep -v 'project website' > docs/index.md
    cp CHANGELOG.md docs/changelogs/changelog.md
    cp CONTRIBUTING.md docs/contribute/contributing.md
    
    # Build the site locally
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 753 bytes
    - Click Count (1)
  2. src/test/java/org/codelibs/core/collection/IndexedIteratorTest.java

            }
        }
    
        /**
         * @throws Exception
         */
        @Test
        public void testForEachLineIterator() throws Exception {
            final StringReader reader = new StringReader("aaa\nbbb\nccc\n");
            for (final Indexed<String> indexed : indexed(iterable(reader))) {
                System.out.println(indexed.getIndex());
                System.out.println(indexed.getElement());
            }
        }
    
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/io/SourceSinkFactories.java

        }
    
        @Override
        public String getSinkContents() throws IOException {
          File file = getFile();
          Reader reader = new InputStreamReader(new FileInputStream(file), UTF_8);
          StringBuilder builder = new StringBuilder();
          CharBuffer buffer = CharBuffer.allocate(100);
          while (reader.read(buffer) != -1) {
            Java8Compatibility.flip(buffer);
            builder.append(buffer);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/core/misc/DynamicProperties.java

            prop.load(inStream);
            properties = prop;
        }
    
        @Override
        public synchronized void load(final Reader reader) throws IOException {
            final Properties prop = new Properties();
            lastModified = propertiesFile.lastModified();
            prop.load(reader);
            properties = prop;
        }
    
        @Override
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Jul 05 00:11:05 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/io/CharSinkTest.java

        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
        assertThat(sink.getString()).isEqualTo(STRING);
      }
    
      public void testWriteFrom_reader() throws IOException {
        StringReader reader = new StringReader(STRING);
        sink.writeFrom(reader);
    
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
        assertThat(sink.getString()).isEqualTo(STRING);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  6. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/PomValidationTask.java

        }
    
        @TaskAction
        public void checkPom() throws Exception {
            try (FileReader fileReader = new FileReader(pomFile.getAsFile().get())) {
                MavenXpp3Reader reader = new MavenXpp3Reader();
                Model model = reader.read(fileReader);
    
                validateString("groupId", model.getGroupId());
                validateString("artifactId", model.getArtifactId());
                validateString("version", model.getVersion());
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3.4K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb1/smb1/SmbComTransactionResponseTest.java

            // After a full read both flags should be set and hasMore should be false
            assertTrue(d.getParametersDone(), "parametersDone should be true after reading");
            assertTrue(d.getDataDone(), "dataDone should be true after reading");
            assertFalse(d.getHasMore(), "hasMore should be false when both packets are fully read");
        }
    
        /**
         * Test partial read scenario where parameters are not fully read
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/SmbPipeInputStream.java

    import jcifs.internal.smb2.ioctl.Smb2IoctlRequest;
    import jcifs.internal.smb2.ioctl.Smb2IoctlResponse;
    import jcifs.internal.smb2.ioctl.SrvPipePeekResponse;
    
    /**
     * Input stream for reading from SMB named pipes.
     *
     * This class provides a stream-based interface for reading
     * data from SMB named pipes over the network.
     *
     * @author mbechler
     */
    public class SmbPipeInputStream extends SmbFileInputStream {
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-rebalance_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = rebalSaveOpts(zb0001)
    	}
    	return
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  10. internal/rest/client.go

    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    				return io.NopCloser(&r), nil
    			}
    		case *strings.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
Back to Top