- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 30 for Stuart (0.15 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt
delegate.cacheConditionalHit(call, cachedResponse) } private fun logWithTime(message: String) { val startNs = startNs val timeMs = if (startNs == null) { // Event occurred before start, for an example an early cancel. 0L } else { TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs) } logger.invoke("[$timeMs ms] $message") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
} }, ) .setPriority(REQUEST_PRIORITY_MEDIUM) .setDirectExecutorAllowed(true) .setTrafficStatsTag(101) .build() req.start() return completableFuture } @Test fun urlConnection() { val conn = engine.openConnection(URL("https://google.com/robots.txt")) as HttpURLConnection val text =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 24 13:19:43 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/http2/Http2FlowControlConnectionListener.kt
*/ class Http2FlowControlConnectionListener : ConnectionListener(), FlowControlListener { val start = System.currentTimeMillis() override fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) { println("${System.currentTimeMillis() - start},$streamId,${windowCounter.unacknowledged},$bufferSize") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
KEEP_OPEN, DISCONNECT_AT_END, UPGRADE_TO_SSL_AT_END, DISCONNECT_AT_START, DISCONNECT_AFTER_REQUEST, DISCONNECT_DURING_REQUEST_BODY, DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
docs/features/connections.md
URLs that share the same address may also share the same underlying TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Viewed (0) -
mockwebserver-junit4/src/main/kotlin/mockwebserver3/junit4/MockWebServerRule.kt
* ``` */ @ExperimentalOkHttpApi class MockWebServerRule : ExternalResource() { val server: MockWebServer = MockWebServer() override fun before() { try { server.start() } catch (e: IOException) { throw RuntimeException(e) } } override fun after() { try { server.shutdown() } catch (e: IOException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.8K bytes - Viewed (1) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
public OAuthSessionFactory(SlackApi slackApi) { this.slackApi = slackApi; } public void start() throws Exception { if (mockWebServer != null) throw new IllegalStateException(); mockWebServer = new MockWebServer(); mockWebServer.setDispatcher(this); mockWebServer.start(slackApi.port); } public HttpUrl newAuthorizeUrl(String scopes, String team, Listener listener) {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
SocketPolicy.SHUTDOWN_INPUT_AT_END -> ShutdownInputAtEnd SocketPolicy.SHUTDOWN_OUTPUT_AT_END -> ShutdownOutputAtEnd SocketPolicy.STALL_SOCKET_AT_START -> StallSocketAtStart SocketPolicy.NO_RESPONSE -> NoResponse SocketPolicy.RESET_STREAM_AT_START -> ResetStreamAtStart(http2ErrorCode) else -> error("Unexpected SocketPolicy: $socketPolicy") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt
testRule.beforeEach(extensionContext) val thread = object : Thread() { override fun run() { throw RuntimeException("boom!") } } thread.start() thread.join() assertFailsWith<AssertionError> { testRule.afterEach(extensionContext) }.also { expected -> assertThat(expected).hasMessage("uncaught exception thrown during test")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
* * Baseline test if we ned to validate OkHttp behaviour against other popular clients. */ class JettyHttpClientTest { private val client = HttpClient() @BeforeEach fun setUp() { client.start() } @AfterEach fun tearDown() { client.stop() } @Test fun get(server: MockWebServer) { server.enqueue(MockResponse(body = "hello, Jetty HTTP Client")) val request =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0)