Read - Code Search

okhttp-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt

  private var outputByteCount = 0L

  fun wrapInput(source: Source): Source {
    return object : ForwardingSource(source) {
      override fun read(
        sink: Buffer,
        byteCount: Long,
      ): Long {
        val result = super.read(sink, byteCount)
        if (result == -1L) return result
        inputByteCount += result
        return result
      }
    }
  }

Plain Text

- Registered: Fri Mar 29 11:42:11 GMT 2024

- Last Modified: Mon Jan 29 22:50:20 GMT 2024

- 1.8K bytes

- Viewed (0)

github.com/square/okhttp

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

   * a default value.
   *
   * If this does read a value, it starts with the tag and length, and reads an entire value,
   * including any potential composed values.
   *
   * If there's nothing to read and no default value, this will throw an exception.
   */
  fun fromDer(reader: DerReader): T

  fun fromDer(byteString: ByteString): T {

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 4.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

    require(length < bytesOut.size - lastFrame.start)

    // Move everything from bytesOut into a new buffer.
    val fullBuffer = Buffer()
    bytesOut.read(fullBuffer, bytesOut.size)

    // Copy back all but what we're truncating.
    fullBuffer.read(bytesOut, lastFrame.start + length)
    outFrames.add(OutFrame(lastFrame.sequence, lastFrame.start, true))
    return writer
  }

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Thu Apr 11 22:09:35 GMT 2024

- 8.7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/Callback.kt

   */
  fun onFailure(
    call: Call,
    e: IOException,
  )

  /**
   * Called when the HTTP response was successfully returned by the remote server. The callback may
   * proceed to read the response body with [Response.body]. The response is still live until its
   * response body is [closed][ResponseBody]. The recipient of the callback may consume the response
   * body on another thread.
   *

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 1.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

    val terminalBitCount: Int

    /** Construct an internal node. */
    constructor() {
      this.children = arrayOfNulls(256)
      this.symbol = 0 // Not read.
      this.terminalBitCount = 0 // Not read.
    }

    /** Construct a terminal node. */
    constructor(symbol: Int, bits: Int) {
      this.children = null
      this.symbol = symbol
      val b = bits and 0x07

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 8.3K bytes

- Viewed (0)

github.com/square/okhttp

okcurl/src/main/kotlin/okhttp3/curl/Main.kt

  val connectTimeout: Int by option(
    "--connect-timeout",
    help = "Maximum time allowed for connection (seconds)",
  ).int().default(DEFAULT_TIMEOUT)

  val readTimeout: Int by option("--read-timeout", help = "Maximum time allowed for reading data (seconds)").int().default(DEFAULT_TIMEOUT)

  val callTimeout: Int by option(
    "--call-timeout",
    help = "Maximum time allowed for the entire call (seconds)",

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 5.7K bytes

- Viewed (1)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

    expectedEvents += "ConnectionAcquired"
    expectedEvents += "RequestHeadersStart"
    expectedEvents += "RequestHeadersEnd"
    expectedEvents += "RequestBodyStart"
    // ... but we can read the response even after writing the request fails.
    expectedEvents += "RequestFailed"
    expectedEvents += "ResponseHeadersStart"
    expectedEvents += "ResponseHeadersEnd"
    expectedEvents += "ResponseBodyStart"

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 9.5K bytes

- Viewed (0)

github.com/square/okhttp

samples/static-server/src/main/java/okhttp3/sample/SampleServer.java

    if (!basePath.endsWith("/")) basePath += "/";

    StringBuilder response = new StringBuilder();
    response.append(String.format("<html><head><title>%s</title></head><body>", basePath));
    response.append(String.format("<h1>%s</h1>", basePath));
    for (String file : directory.list()) {
      response.append(String.format("<div class='file'><a href='%s'>%s</a></div>",

Java

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Wed Jan 02 02:50:44 GMT 2019

- 4.7K bytes

- Viewed (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/Progress.java

      return new ForwardingSource(source) {
        long totalBytesRead = 0L;

        @Override public long read(Buffer sink, long byteCount) throws IOException {
          long bytesRead = super.read(sink, byteCount);
          // read() returns the number of bytes read, or -1 if this source is exhausted.
          totalBytesRead += bytesRead != -1 ? bytesRead : 0;

Java

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sat Jan 12 03:31:36 GMT 2019

- 3.9K bytes

- Viewed (0)

github.com/square/okhttp

samples/slack/src/main/java/okhttp3/slack/RtmSession.java

    if (webSocket != null) throw new IllegalStateException();

    RtmStartResponse rtmStartResponse = slackApi.rtmStart(accessToken);
    webSocket = slackApi.rtm(rtmStartResponse.url, this);
  }

  // TODO(jwilson): can I read the response body? Do I have to?
  //                the body from slack is a 0-byte-buffer
  @Override public synchronized void onOpen(WebSocket webSocket, Response response) {
    System.out.println("onOpen: " + response);
  }

Java

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sat Nov 19 20:16:58 GMT 2016

- 2.4K bytes

- Viewed (0)

Search Options