body - Code Search

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

    server.enqueue(
      MockResponse(
        body = "abc",
        socketPolicy = DoNotReadRequestBody(ErrorCode.NO_ERROR.httpCode),
      ),
    )

    val call =
      client.newCall(
        Request(
          url = server.url("/"),
          body = SlowRequestBody,
        ),
      )

    call.execute().use { response ->
      assertThat(response.body.string()).isEqualTo("abc")
    }

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

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

   * 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.
   *
   * Note that transport-layer success (receiving a HTTP response code, headers and body) does not

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/test/java/okhttp3/internal/http/ExternalHttp2Example.kt

    try {
      println(response.code)
      println("PROTOCOL ${response.protocol}")
      var line: String?
      while (response.body.source().readUtf8Line().also { line = it } != null) {
        println(line)
      }
    } finally {
      response.body.close()
    }
    client.connectionPool.evictAll()
  }

Plain Text

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

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

- 1.4K bytes

- Viewed (0)

github.com/square/okhttp

docs/features/events.md

try (Response response = client.newCall(request).execute()) {
  // Consume and discard the response body.
  response.body().source().readByteString();
}

System.out.println("REQUEST 2 (pooled connection)");
try (Response response = client.newCall(request).execute()) {
  // Consume and discard the response body.
  response.body().source().readByteString();
}
```

And the listener prints the corresponding events:

```

Plain Text

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

- Last Modified: Sun Feb 06 02:19:09 GMT 2022

- 7.7K bytes

- Viewed (0)

github.com/square/okhttp

samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

      MockResponse.Builder()
        .body("hello, Java HTTP Client")
        .build(),
    )

    val request =
      HttpRequest.newBuilder(server.url("/").toUri())
        .header("Accept", "text/plain")
        .build()

    val response = httpClient.send(request, BodyHandlers.ofString())
    assertThat(response.statusCode()).isEqualTo(200)
    assertThat(response.body()).isEqualTo("hello, Java HTTP Client")

Plain Text

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

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

- 2.7K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/README.md

```

Your unit tests might move the `server` into a field so you can shut it down
from your test's `tearDown()`.

### API

#### MockResponse

Mock responses default to an empty response body and a `200` status code.
You can set a custom body with a string, input stream or byte array. Also
add headers with a fluent builder API.

```java
MockResponse response = new MockResponse()

Plain Text

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

- Last Modified: Sun Dec 17 15:34:10 GMT 2023

- 5K bytes

- Viewed (1)

github.com/square/okhttp

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

    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>",
          basePath + file, file));
    }
    response.append("</body></html>");

    return new MockResponse()
        .setStatus("HTTP/1.1 200")

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/slack/src/main/java/okhttp3/slack/SlackApi.java

    Call call = httpClient.newCall(request);
    try (Response response = call.execute()) {
      JsonAdapter<OAuthSession> jsonAdapter = moshi.adapter(OAuthSession.class);
      return jsonAdapter.fromJson(response.body().source());
    }
  }

  /** See https://api.slack.com/methods/rtm.start. */
  public RtmStartResponse rtmStart(String accessToken) throws IOException {
    HttpUrl url = baseUrl.newBuilder("rtm.start")

Java

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

- Last Modified: Fri Jul 06 19:30:55 GMT 2018

- 4.4K bytes

- Viewed (1)

github.com/square/okhttp

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

        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new PostFile().run();
  }

Java

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

- Last Modified: Sat May 25 18:02:55 GMT 2019

- 1.5K bytes

- Viewed (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/kt/Authenticate.kt

        .build()

    client.newCall(request).execute().use { response ->
      if (!response.isSuccessful) throw IOException("Unexpected code $response")

      println(response.body.string())
    }
  }
}

fun main() {
  Authenticate().run()

Plain Text

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

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

- 1.9K bytes

- Viewed (0)

Search Options