- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for Dadd (0.14 sec)
-
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
MockResponse.Builder() .setHeader("Content-Type", "text/event-stream") .chunkedBody( """ |event: add |data: 73857293 | |event: remove |data: 2153 | |event: add |data: 113411 | | """.trimMargin(), 8, ) .build(), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
lock.assertHeld() task.nextExecuteNanoTime = -1L val queue = task.queue!! queue.futureTasks.remove(task) readyQueues.remove(queue) queue.activeTask = task busyQueues.add(queue) } private fun runTask(task: Task) { val currentThread = Thread.currentThread() val oldName = currentThread.name currentThread.name = task.name var delayNanos = -1L try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.closeConnections(100L)).isEqualTo(50L) assertThat(pool.connectionCount()).isEqualTo(2) assertThat(c1.socket().isClosed).isFalse() assertThat(c2.socket().isClosed).isFalse() // Add a third connection val c3 = factory.newConnection(pool, routeC1, 75L) // The third connection bounces the first. assertThat(pool.closeConnections(100L)).isEqualTo(0L)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
build.gradle.kts
// https://publicobject.com/2023/04/16/read-a-project-file-in-a-kotlin-multiplatform-test/ tasks.withType<Test>().configureEach { environment("OKHTTP_ROOT", rootDir) } if (platform == "jdk8alpn") { // Add alpn-boot on Java 8 so we can use HTTP/2 without a stable API. val alpnBootVersion = alpnBootVersion() if (alpnBootVersion != null) { val alpnBootJar = configurations.detachedConfiguration(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:32:42 GMT 2024 - 8.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
if (attempts.count > 0) { clientListener.setNextEventDelegate(this) webSockets.add(client.newWebSocket(request, clientListener)) attempts.countDown() } } } clientListener.setNextEventDelegate(reconnectOnFailure) webSockets.add(client.newWebSocket(request, clientListener)) attempts.await() synchronized(webSockets) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
connection: Connection, ) { connections.add(connection as RealConnection) } }, ).build() val call1 = localClient.newCall(Request(server.url("/"))) val response1 = call1.execute() assertThat(response1.body.string()).isEqualTo("ABC") // Add delays for DISCONNECT_AT_END to propogate waitForConnectionShutdown(connections[0])
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
if (asyncCall.callsPerHost.get() >= this.maxRequestsPerHost) continue // Host max capacity. i.remove() asyncCall.callsPerHost.incrementAndGet() executableCalls.add(asyncCall) runningAsyncCalls.add(asyncCall) } isRunning = runningCallsCount() > 0 } // Avoid resubmitting if we can't logically progress
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
try { val fromSource = from.source().buffer() val fromSink = from.sink().buffer() hello(fromSource, fromSink) acceptCommand(from.inetAddress, fromSource, fromSink) openSockets.add(from) } catch (e: IOException) { logger.log(Level.WARNING, "$name failed", e) from.closeQuietly() } } } private fun hello( fromSource: BufferedSource,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} @Test fun headersBuilder() { var builder: Headers.Builder = Headers.Builder() builder = builder.add("") builder = builder.add("", "") builder = builder.addUnsafeNonAscii("", "") builder = builder.addAll(headersOf()) builder = builder.add("", Date(0L)) builder = builder.add("", Instant.EPOCH) builder = builder.set("", "") builder = builder.set("", Date(0L))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
queueSize += data.size.toLong() messageAndCloseQueue.add(Message(formatOpcode, data)) runWriter() return true } @Synchronized fun pong(payload: ByteString): Boolean { // Don't send pongs after we've failed or sent the close frame. if (failed || enqueuedClose && messageAndCloseQueue.isEmpty()) return false pongQueue.add(payload) runWriter() return true }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0)