- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 90 for closed (0.3 sec)
-
okhttp/src/main/kotlin/okhttp3/RequestBody.kt
* due to any of: * * * A stale connection. The request was made on a reused connection and that reused connection * has since been closed by the server. * * A client timeout (HTTP 408). * * A authorization challenge (HTTP 401 and 407) that is satisfied by the [Authenticator]. * * A retryable server failure (HTTP 503 with a `Retry-After: 0` response header).
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Jan 25 14:41:37 GMT 2024 - 9.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* This method returns true if the message was enqueued. Messages that would overflow the outgoing * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket. * This method returns false in that case, and in any other case where this web socket is closing, * closed, or canceled. * * This method returns immediately. */ fun send(text: String): Boolean /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseCommonTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyTest.kt
val source = Buffer().writeUtf8("hello") return object : ForwardingSource(source) { override fun close() { closed = true super.close() } }.buffer() } } body.source().close() assertThat(closed).isTrue() } @Test fun throwingUnderlyingSourceClosesQuietly() { val body: ResponseBody =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
messageBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(0L) toggleMask(maskCursor, maskKey) maskCursor.close() } } sinkBuffer.write(messageBuffer, dataSize) sink.emit() } override fun close() { messageDeflater?.close() }
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/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/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)