Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 55 for readByte (0.06 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

      var commaFound = false
      loop@ while (!exhausted()) {
        when (this[0]) {
          ','.code.toByte() -> {
            // Consume ','.
            readByte()
            commaFound = true
          }
    
          ' '.code.toByte(), '\t'.code.toByte() -> {
            readByte()
            // Consume space or tab.
          }
    
          else -> {
            break@loop
          }
        }
      }
      return commaFound
    }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  2. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

          when (select(optionsDot)) {
            DELIMITER_DOT -> {
              if (readByte() != '.'.code.toByte()) throw IOException("expected '..'")
              readHexadecimalUnsignedLong()
            }
    
            else -> {
              sourceCodePoint0
            }
          }
    
        skipWhitespace()
        if (readByte() != ';'.code.toByte()) throw IOException("expected ';'")
    
        // "valid" or "mapped"
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  3. src/bytes/buffer_test.go

    	}
    
    	// after successful read
    	if _, err := b.ReadBytes('m'); err != nil {
    		t.Fatalf("ReadBytes: %v", err)
    	}
    	if err := b.UnreadByte(); err != nil {
    		t.Fatalf("UnreadByte: %v", err)
    	}
    	c, err := b.ReadByte()
    	if err != nil {
    		t.Fatalf("ReadByte: %v", err)
    	}
    	if c != 'm' {
    		t.Errorf("ReadByte = %q; want %q", c, 'm')
    	}
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

              dynamicTable[index] = entry
            }
            dynamicTableByteCount += delta
          }
    
          @Throws(IOException::class)
          private fun readByte(): Int = source.readByte() and 0xff
    
          @Throws(IOException::class)
          fun readInt(
            firstByte: Int,
            prefixMask: Int,
          ): Int {
            val prefix = firstByte and prefixMask
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 23.2K bytes
    - Click Count (0)
  5. src/main/java/jcifs/pac/PacDataInputStream.java

        }
    
        /**
         * Reads a single byte value.
         * @return the byte value
         * @throws IOException if an I/O error occurs
         */
        public byte readByte() throws IOException {
            return this.dis.readByte();
        }
    
        /**
         * Reads a 16-bit short value with proper alignment and byte order.
         * @return the short value in little-endian format
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  6. internal/ringbuffer/ring_buffer_test.go

    			n, err := rb.Read(buf[:readRng.Intn(len(buf))])
    			readBytes += n
    			read.Write(buf[:n])
    			debugln("READ 1\t", n, readBytes)
    			if err != nil {
    				readErr = err
    				break
    			}
    
    			// ReadByte
    			b, err := rb.ReadByte()
    			if err != nil {
    				readErr = err
    				break
    			}
    			readBytes++
    			read.Write([]byte{b})
    			debugln("READ 2\t", 1, readBytes)
    
    			// TryRead
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  7. internal/ringbuffer/ring_buffer.go

    		c2 := n - c1
    		copy(p[c1:], r.buf[0:c2])
    	}
    	r.r = (r.r + n) % r.size
    
    	r.isFull = false
    
    	return n, r.readErr(true)
    }
    
    // ReadByte reads and returns the next byte from the input or ErrIsEmpty.
    func (r *RingBuffer) ReadByte() (b byte, err error) {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err = r.readErr(true); err != nil {
    		return 0, err
    	}
    	for r.w == r.r && !r.isFull {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        v1Creator.setString(1, "BBbb")
        v1Creator.commit()
    
        cache["k1"]!!.use { snapshot1 ->
          val inV1 = snapshot1.getSource(0).buffer()
          assertThat(inV1.readByte()).isEqualTo('A'.code.toByte())
          assertThat(inV1.readByte()).isEqualTo('A'.code.toByte())
    
          val v1Updater = cache.edit("k1")!!
          v1Updater.setString(0, "CCcc")
          v1Updater.setString(1, "DDdd")
          v1Updater.commit()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 59.4K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/io/ByteStreamsTest.java

      public void testNewDataInput_readByte() {
        ByteArrayDataInput in = ByteStreams.newDataInput(bytes);
        for (byte aByte : bytes) {
          assertEquals(aByte, in.readByte());
        }
        IllegalStateException expected = assertThrows(IllegalStateException.class, in::readByte);
        assertThat(expected).hasCauseThat().isInstanceOf(EOFException.class);
      }
    
      public void testNewDataInput_readUnsignedByte() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 22K bytes
    - Click Count (0)
  10. src/bytes/buffer.go

    	if b.off > 0 {
    		b.off--
    	}
    	return nil
    }
    
    // ReadBytes reads until the first occurrence of delim in the input,
    // returning a slice containing the data up to and including the delimiter.
    // If ReadBytes encounters an error before finding a delimiter,
    // it returns the data read before the error and the error itself (often [io.EOF]).
    // ReadBytes returns err != nil if and only if the returned data does not end in
    // delim.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
Back to Top