lead - Code Search

mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

    assertThat(inputStream!!.read()).isEqualTo('A'.code)
    assertThat(inputStream.read()).isEqualTo('B'.code)
    assertThat(inputStream.read()).isEqualTo('C'.code)
    assertThat(inputStream.read()).isEqualTo('D'.code)
    assertThat(inputStream.read()).isEqualTo('E'.code)
    assertThat(inputStream.read()).isEqualTo('F'.code)
    assertThat(inputStream.read()).isEqualTo(-1)

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Sun Aug 03 22:38:00 UTC 2025

- 28K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

    assertEquals(0, ticker.read());
    assertEquals(10, ticker.read());
    assertEquals(20, ticker.read());
  }

  public void testAutoIncrementStep_millis() {
    FakeTicker ticker = new FakeTicker().setAutoIncrementStep(1, MILLISECONDS);
    assertEquals(0, ticker.read());
    assertEquals(1000000, ticker.read());
    assertEquals(2000000, ticker.read());
  }

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Aug 07 16:05:33 UTC 2025

- 6.5K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java

    ByteSource source = out.asByteSource();

    out.write(data);
    assertTrue(Arrays.equals(data, source.read()));

    out.reset();
    assertTrue(Arrays.equals(new byte[0], source.read()));

    out.write(data);
    assertTrue(Arrays.equals(data, source.read()));

    out.close();
  }

  private static boolean isAndroid() {

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 5.6K bytes

- Viewed (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/io/ContentCache.java

        }
    }

    /**
     * Returns an InputStream to read the content from the cache.
     * If the content is stored in a file, a FileInputStream is returned.
     * Otherwise, a ByteArrayInputStream is returned to read the data from memory.
     *
     * @return an InputStream to read the cached content
     * @throws IOException if an I/O error occurs while creating the InputStream
     */

Registered: Thu Sep 04 15:34:10 UTC 2025

- Last Modified: Sat Jul 05 01:38:18 UTC 2025

- 3.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/RelayTest.kt

    val source = relay.newSource()
    val sourceBuffer = Buffer()
    assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5)
    assertThat(sourceBuffer.readUtf8()).isEqualTo("abcde")
    assertThat(source.read(sourceBuffer, 1024)).isEqualTo(8)
    assertThat(sourceBuffer.readUtf8()).isEqualTo("fghijklm")
    assertThat(source.read(sourceBuffer, 1024)).isEqualTo(-1)
    assertThat(sourceBuffer.size).isEqualTo(0)
    source.close()

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 8.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/searchlog/admin_searchlog.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.searchlog_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Feb 13 07:47:04 UTC 2020

- 16K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

) {
  private val countingSource: CountingSource = CountingSource(source)
  private val source: BufferedSource = countingSource.buffer()

  /** Total bytes read thus far. */
  private val byteCount: Long
    get() = countingSource.bytesRead - source.buffer.size

  /** How many bytes to read before [peekHeader] should return false, or -1L for no limit. */
  private var limit = -1L

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 10.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

    val body = body("")
    val bytes = body.byteStream()
    assertThat(bytes.read()).isEqualTo(-1)
  }

  @Test
  fun byteStreamSeesBom() {
    val body = body("efbbbf68656c6c6f")
    val bytes = body.byteStream()
    assertThat(bytes.read()).isEqualTo(0xef)
    assertThat(bytes.read()).isEqualTo(0xbb)
    assertThat(bytes.read()).isEqualTo(0xbf)

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 12.4K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/nio/ChannelUtil.java

     *            The byte buffer. Must not be {@literal null}.
     * @return The number of bytes read.
     */
    public static int read(final FileChannel channel, final ByteBuffer buffer) {
        assertArgumentNotNull("channel", channel);
        assertArgumentNotNull("buffer", buffer);

        try {
            return channel.read(buffer);
        } catch (final IOException e) {
            throw new IORuntimeException(e);

Registered: Fri Sep 05 20:58:11 UTC 2025

- Last Modified: Thu Jul 31 08:16:49 UTC 2025

- 5.6K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CharSequenceReaderTest.java

    assertEquals(-1, reader.read());
    assertEquals(-1, reader.read(new char[10], 0, 10));
    assertEquals(-1, reader.read(CharBuffer.allocate(10)));
    assertEquals(0, reader.skip(10));
  }

  private static String readFully(CharSequenceReader reader) throws IOException {
    StringBuilder builder = new StringBuilder();
    int read;
    while ((read = reader.read()) != -1) {
      builder.append((char) read);

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 6.6K bytes

- Viewed (0)

Search Options