- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 131 for Close (0.14 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Confirm all sent messages were received, followed by a client-initiated close. val server = serverListener.assertOpen() for (i in 0 until messageCount) { serverListener.assertBinaryMessage(message) } serverListener.assertClosing(1001, "") // When the server acknowledges the close the connection shuts down gracefully. server.close(1000, null) clientListener.assertClosing(1000, "")
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/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) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
SocketException exception = new SocketException(); exception.initCause(e); throw exception; } } @Override public void close() throws IOException { serverSocketChannel.close(); } }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 3.1K 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/MultipartReader.kt
* part is particularly large or if the underlying source is particularly slow, the [nextPart] call * may be slow! * * Closing a part **does not** close this multipart reader; callers must explicitly close this with * [close]. * * [rfc_2046]: http://www.ietf.org/rfc/rfc2046.txt */ class MultipartReader @Throws(IOException::class) constructor( private val source: BufferedSource,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K 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) -
okhttp/src/test/java/okhttp3/HeadersTest.kt
} } @Test fun headersEquals() { val headers1 = Headers.Builder() .add("Connection", "close") .add("Transfer-Encoding", "chunked") .build() val headers2 = Headers.Builder() .add("Connection", "close") .add("Transfer-Encoding", "chunked") .build() assertThat(headers2).isEqualTo(headers1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0)