- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 39 for readSlice (0.05 seconds)
-
src/bufio/bufio.go
// part of the line returned by ReadLine. func (b *Reader) ReadLine() (line []byte, isPrefix bool, err error) { line, err = b.ReadSlice('\n') if err == ErrBufferFull { // Handle the case where "\r\n" straddles the buffer. if len(line) > 0 && line[len(line)-1] == '\r' { // Put the '\r' back on buf and drop it from line. // Let the next call to ReadLine check for "\r\n". if b.r == 0 {Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Sep 03 14:04:47 GMT 2025 - 22K bytes - Click Count (0) -
src/bytes/buffer.go
func (b *Buffer) ReadBytes(delim byte) (line []byte, err error) { slice, err := b.readSlice(delim) // return a copy of slice. The buffer's backing array may // be overwritten by later calls. line = append(line, slice...) return line, err } // readSlice is like ReadBytes but returns a reference to internal buffer data. func (b *Buffer) readSlice(delim byte) (line []byte, err error) { i := IndexByte(b.buf[b.off:], delim)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Nov 14 19:01:17 GMT 2025 - 16.5K bytes - Click Count (0) -
src/bufio/bufio_test.go
(*Reader).ReadBytes, (*Reader).ReadSlice, func(r *Reader, delim byte) ([]byte, error) { data, err := r.ReadString(delim) return []byte(data), err }, // ReadLine doesn't fit the data/pattern easily // so we leave it out. It should be covered via // the ReadSlice test since ReadLine simply calls // ReadSlice, and it's that function that handles // the last byte. }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 07 01:08:54 GMT 2025 - 51.6K bytes - Click Count (0) -
cmd/streaming-signature-v4.go
// The returned bytes are owned by the bufio.Reader // so they are only valid until the next bufio read. func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) { buf, err := b.ReadSlice('\n') if err != nil { // We always know when EOF is coming. // If the caller asked for a line, there should be a line. switch err { case io.EOF: err = io.ErrUnexpectedEOF
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.2K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/internal/compat/interactivity/LegacyPlexusInteractivity.java
} } @Override public List<String> readMultipleLines() throws IOException { List<String> lines = new ArrayList<>(); for (String line = readLine(); line != null && !line.isEmpty(); line = readLine()) { lines.add(line); } return lines; } @Override public void write(String line) throws IOException { try {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Apr 03 13:48:41 GMT 2025 - 5.2K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/FindBrokenInternalLinks.java
File sourceFile = getReleaseNotesFile().get().getAsFile(); try (BufferedReader br = new BufferedReader(new FileReader(sourceFile))) { String line = br.readLine(); while (line != null) { lineNumber++; gatherDeadUserGuideLinksInLineReleaseNotes(sourceFile, line, lineNumber, errorsForFile);
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue May 27 09:07:14 GMT 2025 - 18.1K bytes - Click Count (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
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") assertThat(request.headers["Accept-Language"]).isEqualTo("en-US")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Aug 03 22:38:00 GMT 2025 - 28K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/HeadersReader.kt
/** Read a single line counted against the header size limit. */ fun readLine(): String { val line = source.readUtf8LineStrict(headerLimit) headerLimit -= line.length.toLong() return line } /** Reads headers or trailers. */ fun readHeaders(): Headers { val result = Headers.Builder() while (true) { val line = readLine() if (line.isEmpty()) break result.addLenient(line) }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Decrypt.java
super(messageBuilderFactory, secDispatcher); } @Override protected int doExecute(EncryptContext context) throws Exception { String encrypted = context.reader.readLine("Enter the password to decrypt: "); if (secDispatcher.isAnyEncryptedString(encrypted)) { context.terminal.writer().println(secDispatcher.decrypt(encrypted)); return OK; } else {
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Dec 17 09:50:45 GMT 2024 - 2.1K bytes - Click Count (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
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") assertThat(request.getHeader("Accept-Language")).isEqualTo("en-US")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0)