- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 126 for closure (0.15 sec)
-
okhttp/src/test/java/okhttp3/RequestTest.kt
} @Test fun file() { val file = File.createTempFile("RequestTest", "tmp") val writer = FileWriter(file) writer.write("abc") writer.close() val contentType = "text/plain".toMediaType() val body: RequestBody = file.asRequestBody(contentType) assertThat(body.contentType()).isEqualTo(contentType) assertThat(body.contentLength()).isEqualTo(3)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
/** * Half close connection (InputStream for client) after reading the request but before * writing the response. Use this to simulate late connection pool failures. */ object HalfCloseAfterRequest : SocketPolicy /** Close connection after reading half of the request body (if present). */ object DisconnectDuringRequestBody : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
MockResponse.Builder() .body("Hello!") .setHeader("Content-Type", PLAIN) .build(), ) val response = client.newCall(request().build()).execute() response.body.close() applicationLogs .assertLogEqual("--> GET $url") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 6-byte body\)""")) .assertNoMoreLogs() networkLogs
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/http1/Http1ExchangeCodec.kt
* [chunked][newChunkedSink]. * 3. Write to and then close that sink. * 4. [Read response headers][readResponseHeaders]. * 5. Open a source to read the response body. Either [fixed-length][newFixedLengthSource], * [chunked][newChunkedSource] or [unknown][newUnknownLengthSource]. * 6. Read from and close that source. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
) val part = parts.nextPart()!! parts.close() assertFailsWith<IllegalStateException> { part.body.request(10) }.also { expected -> assertThat(expected).hasMessage("closed") } } @Test fun `cannot call nextPart after calling close`() { val parts = MultipartReader( boundary = "simple boundary",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
if (hasErrors) { return } try { super.flush() } catch (e: IOException) { hasErrors = true onException(e) } } override fun close() { try { super.close() } catch (e: IOException) { hasErrors = true onException(e) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
init { val source = snapshot.getSource(ENTRY_BODY) bodySource = object : ForwardingSource(source) { @Throws(IOException::class) override fun close() { snapshot.close() super.close() } }.buffer() } override fun contentType(): MediaType? = contentType?.toMediaTypeOrNull()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
server.enqueue( MockResponse( code = 408, headers = headersOf("Connection", "Close"), body = "You took too long!", socketPolicy = DisconnectAtEnd, ), ) server.enqueue( MockResponse( code = 408, headers = headersOf("Connection", "Close"), body = "You took too long!", socketPolicy = DisconnectAtEnd, ), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0)