Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for readSlice (0.05 sec)

  1. 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 {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. 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)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 17:38:56 UTC 2025
    - 16K bytes
    - Viewed (0)
  3. 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.
    	}
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/netbios/Lmhosts.java

            return result;
        }
    
        void populate(final Reader r, final CIFSContext tc) throws IOException {
            String line;
            final BufferedReader br = new BufferedReader(r);
    
            while ((line = br.readLine()) != null) {
                line = line.toUpperCase().trim();
                if (line.length() == 0) {
                    continue;
                }
                if (line.charAt(0) == '#') {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  6. 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")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Aug 03 22:38:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  7. 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 {
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Apr 03 13:48:41 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  8. 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)
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/admin/sereq/AdminSereqAction.java

            final StringBuilder buf = new StringBuilder(1000);
            try (final BufferedReader reader = new BufferedReader(new InputStreamReader(form.requestFile.getInputStream(), Constants.UTF_8))) {
                header = ReaderUtil.readLine(reader);
                if (header == null) {
                    throwValidationError(messages -> messages.addErrorsInvalidHeaderForRequestFile(GLOBAL, "no header"),
                            () -> asListHtml(this::saveToken));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  10. 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")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
Back to top