- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for Beek (0.12 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
) { chunked = true } } val peek = dispatcher.peek() for (response in peek.informationalResponses) { writeHttpResponse(socket, sink, response) } var hasBody = false val policy = dispatcher.peek() val requestBodySink = requestBody.withThrottlingAndSocketPolicy( policy = policy,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* can return other values to test HTTP edge cases, such as unhappy socket policies or throttled * request bodies. */ open fun peek(): MockResponse { return MockResponse(socketPolicy = KeepOpen) } /** * Release any resources held by this dispatcher. Any requests that are currently being dispatched
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
if (frameLength > 0L) { source.readFully(controlFrameBuffer, frameLength) if (!isClient) { controlFrameBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(0) toggleMask(maskCursor, maskKey!!) maskCursor.close() } } when (opcode) { OPCODE_CONTROL_PING -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public abstract class okhttp3/mockwebserver/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse; public fun peek ()Lokhttp3/mockwebserver/MockResponse; public fun shutdown ()V } public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable { public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 10.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
name: String, defaultValue: String?, ): String? = headers[name] ?: defaultValue @Throws(IOException::class) fun Response.commonPeekBody(byteCount: Long): ResponseBody { val peeked = body.source().peek() val buffer = Buffer() peeked.request(byteCount) buffer.write(peeked, minOf(byteCount, peeked.buffer.size)) return buffer.asResponseBody(body.contentType(), buffer.size) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 5.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
// other threads waiting on take() will also return. if (result == DEAD_LETTER) responseQueue.add(DEAD_LETTER) return result } override fun peek(): MockResponse { return responseQueue.peek() ?: failFastResponse ?: super.peek() } open fun enqueueResponse(response: MockResponse) { responseQueue.add(response) } open fun clear() { responseQueue.clear() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
@Test @Ignore fun dispatcherFromMockWebServer() { val dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse = TODO() override fun peek(): MockResponse = TODO() override fun shutdown() = TODO() } } @Test @Ignore fun mockResponse() { var mockResponse: MockResponse = MockResponse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
sinkBuffer.write(maskKey) if (length > 0) { val payloadStart = sinkBuffer.size sinkBuffer.write(payload) sinkBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(payloadStart) toggleMask(maskCursor, maskKey) maskCursor.close() } } else { sinkBuffer.writeByte(b1) sinkBuffer.write(payload) } sink.flush() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.gz
is-a-candidate.org is-a-caterer.com is-a-celticsfan.org is-a-chef.com is-a-chef.net is-a-chef.org is-a-conservative.com is-a-cpa.com is-a-cubicle-slave.com is-a-democrat.com is-a-designer.com is-a-doctor.com is-a-financialadvisor.com is-a-geek.com is-a-geek.net is-a-geek.org is-a-green.com is-a-guru.com is-a-hard-worker.com is-a-hunter.com is-a-knight.org is-a-landscaper.com is-a-lawyer.com is-a-liberal.com is-a-libertarian.com is-a-linux-user.org is-a-llama.com is-a-musician.com is-a-nascarfan.com is-a-nurse.com...
Others - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 40.4K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
// seat : 2014-05-22 SEAT, S.A. (Sociedad Unipersonal) seat // secure : 2015-08-27 Amazon Registry Services, Inc. secure // security : 2015-05-14 XYZ.COM LLC security // seek : 2014-12-04 Seek Limited seek // select : 2015-10-08 Registry Services, LLC select // sener : 2014-10-24 Sener IngenierĂa y Sistemas, S.A. sener // services : 2014-02-27 Binky Moon, LLC services
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 240.3K bytes - Viewed (3)