- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 283 for close (0.13 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt
@RegisterExtension val clientTestRule = OkHttpClientTestRule() private var client = clientTestRule.newClient() @AfterEach internal fun tearDown() { factory.close() } @Test fun nonRetryableIOException() { val exception = IOException("Non-handshake exception") assertThat(retryTlsHandshake(exception)).isFalse() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
) { check(!closed) { "closed" } checkOffsetAndCount(source.size, 0, byteCount) sink.write(source, byteCount) } override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout)
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) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/SourcesRepository.kt
.first { it.normalizedPath == sourceNormalizedPath } .let(transform) } override fun close() { val errors = mutableListOf<Exception>() openKotlinCompilationUnitsByRoot.values.forEach { unit -> try { unit.close() } catch (ex: Exception) { errors.add(ex) } }
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Feb 20 16:37:41 GMT 2023 - 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/http/CallServerInterceptor.kt
} else { response.newBuilder() .body(exchange.openResponseBody(response)) .build() } if ("close".equals(response.request.header("Connection"), ignoreCase = true) || "close".equals(response.header("Connection"), ignoreCase = true) ) { exchange.noNewExchangesOnConnection() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
latch.countDown() } @Throws(IOException::class) override fun onResponse( call: Call, response: Response, ) { response.close() latch.countDown() } }, ) latch.await() assertThat(call.isCanceled()).isTrue() assertThat(exceptionRef.get()).isNotNull() } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
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/main/kotlin/okhttp3/OkHttpClient.kt
* * ```java * client.connectionPool().evictAll(); * ``` * * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls * against a cache that is closed, and doing so will cause the call to crash. * * ```java * client.cache().close(); * ``` * * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they * remain idle.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
// Write a frame. val length = (end - start).toInt() outputStream.write(outBytes, start.toInt(), length) // If the last frame was truncated, immediately close the connection. if (truncated) { socket.close() } } else { // read a frame val inFrame = InFrame(i, reader) reader.nextFrame(false, inFrame) inFrames.add(inFrame) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
api/go1.8.txt
pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface { Close, ColumnTypeDatabaseTypeName, Columns, Next } pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface, Close() error pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface, Columns() []string
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Wed Dec 21 05:25:57 GMT 2016 - 16.3K bytes - Viewed (0)