Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 21 for ReadByte (0.19 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

    		buf.WriteByte(testString[1])
    		c, err := buf.ReadByte()
    		if want := testString[1]; err != nil || c != want {
    			t.Errorf("ReadByte: got (%q, %v), want (%q, %v)", c, err, want, nil)
    		}
    		c, err = buf.ReadByte()
    		if err != io.EOF {
    			t.Errorf("ReadByte: got (%q, %v), want (%q, %v)", c, err, byte(0), io.EOF)
    		}
    	}
    }
    
    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. 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)
  6. 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)
  7. src/bytes/buffer.go

    		n = m
    	}
    	data := b.buf[b.off : b.off+n]
    	b.off += n
    	if n > 0 {
    		b.lastRead = opRead
    	}
    	return data
    }
    
    // ReadByte reads and returns the next byte from the buffer.
    // If no byte is available, it returns error [io.EOF].
    func (b *Buffer) ReadByte() (byte, error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, io.EOF
    	}
    	c := b.buf[b.off]
    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)
  8. android/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)
  9. src/bufio/bufio.go

    	n = copy(p, b.buf[b.r:b.w])
    	b.r += n
    	b.lastByte = int(b.buf[b.r-1])
    	b.lastRuneSize = -1
    	return n, nil
    }
    
    // ReadByte reads and returns a single byte.
    // If no byte is available, returns an error.
    func (b *Reader) ReadByte() (byte, error) {
    	b.lastRuneSize = -1
    	for b.r == b.w {
    		if b.err != nil {
    			return 0, b.readErr()
    		}
    		b.fill() // buffer is empty
    	}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/io/ByteStreams.java

          try {
            return input.readBoolean();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public byte readByte() {
          try {
            return input.readByte();
          } catch (EOFException e) {
            throw new IllegalStateException(e);
          } catch (IOException impossible) {
            throw new AssertionError(impossible);
          }
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
Back to Top