- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 298 for Closes (0.27 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
@SuppressSignatureCheck sealed class ConnectionEvent { abstract val timestampNs: Long open val connection: Connection? get() = null /** Returns if the event closes this event, or null if this is no open event. */ open fun closes(event: ConnectionEvent): Boolean? = null val name: String get() = javaClass.simpleName data class ConnectStart( override val timestampNs: Long, val route: Route,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt
@SuppressSignatureCheck sealed class CallEvent { abstract val timestampNs: Long abstract val call: Call val name: String get() = javaClass.simpleName /** Returns if the event closes this event, or null if this is no open event. */ open fun closes(event: CallEvent): Boolean? = null data class ProxySelectStart( override val timestampNs: Long, override val call: Call, val url: HttpUrl, ) : CallEvent()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.7K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
/kind api-change /kind deprecation /kind failing-test /kind flake /kind regression --> #### What this PR does / why we need it: #### Which issue(s) this PR fixes: <!-- *Automatically closes linked issue when PR is merged. Usage: `Fixes #<issue number>`, or `Fixes (paste link of issue)`. _If PR is about `failing-tests or flakes`, please post the related issues/tests in a comment and do not use `Fixes`_* --> Fixes #
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Sun Aug 01 08:59:21 GMT 2021 - 2.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
if (eventSequence.isEmpty()) { assertThat(e).isInstanceOf(ConnectionEvent.ConnectStart::class.java) } else { eventSequence.forEach loop@{ when (e.closes(it)) { null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* limitations under the License. */ package okhttp3 import okio.IOException /** * Listener for connection events. Extend this class to monitor the new connections and closes. * * All event methods must execute fast, without external locking, cannot throw exceptions, * attempt to mutate the event parameters, or be reentrant back into the client.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
@SafeVarargs internal fun <T> immutableListOf(vararg elements: T): List<T> { return Collections.unmodifiableList(listOf(*elements.clone())) } /** Closes this, ignoring any checked exceptions. */ internal fun Socket.closeQuietly() { try { close() } catch (e: AssertionError) { throw e } catch (rethrown: RuntimeException) { if (rethrown.message == "bio == null") {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (civilizedFileSystem) return fileSource lockingSourceCount++ return object : ForwardingSource(fileSource) { private var closed = false override fun close() { super.close() if (!closed) { closed = true synchronized(this@DiskLruCache) { lockingSourceCount-- if (lockingSourceCount == 0 && zombie) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
fun receivedResponseAtMillis(): Long = receivedResponseAtMillis /** * Closes the response body. Equivalent to `body().close()`. * * Prior to OkHttp 5.0, it was an error to close a response that is not eligible for a body. This * includes the responses returned from [cacheResponse], [networkResponse], and [priorResponse]. */ override fun close() = commonClose() override fun toString(): String = commonToString()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0)