- Sort Score
- Num 10 results
- Language All
Results 431 - 440 of 1,047 for readFn (0.23 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 readCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12K bytes - Click Count (0) -
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) -
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) -
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)