- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for remove (0.5 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
assertThat(callbacks.remove()).isEqualTo(Event(null, "add", "73857293")) assertThat(callbacks.remove()).isEqualTo(Event(null, "remove", "2153")) assertThat(callbacks.remove()).isEqualTo(Event(null, "add", "113411")) } @Test fun commentsIgnored() { consumeEvents( """ |: test stream | |data: first event |id: 1 | | """.trimMargin(), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
return eventClass.cast(event) } } } catch (e: NoSuchElementException) { throw AssertionError("full event sequence: $fullEventSequence", e) } } /** * Remove and return the next event from the recorded sequence. * * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
addresses: List<InetAddress>, ): FakeDns { hostAddresses[hostname] = addresses return this } /** Clears the results for `hostname`. */ fun clear(hostname: String): FakeDns { hostAddresses.remove(hostname) return this } @Throws(UnknownHostException::class) fun lookup( hostname: String, index: Int, ): InetAddress { return hostAddresses[hostname]!![index] }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
import java.io.IOException import java.util.concurrent.TimeUnit /** * Observes, modifies, and potentially short-circuits requests going out and the corresponding * responses coming back in. Typically interceptors add, remove, or transform headers on the request * or response. * * Implementations of this interface throw [IOException] to signal connectivity failures. This
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
fun connectionCount(): Int = delegate.connectionCount() internal val connectionListener: ConnectionListener get() = delegate.connectionListener /** Close and remove all idle connections in the pool. */ fun evictAll() { delegate.evictAll() } /** * Sets a policy that applies to [address]. * Overwrites any existing policy for that address. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt
faulty: Boolean, ) { if (faulty) { writeFaults.add(file) } else { writeFaults.remove(file) } } fun setFaultyDelete( file: Path, faulty: Boolean, ) { if (faulty) { deleteFaults.add(file) } else { deleteFaults.remove(file) } } fun setFaultyRename( file: Path, faulty: Boolean, ) { if (faulty) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
try { removeMethod.invoke(null, sslSocket) } catch (e: IllegalAccessException) { throw AssertionError("failed to remove ALPN", e) } catch (e: InvocationTargetException) { throw AssertionError("failed to remove ALPN", e) } } override fun getSelectedProtocol(sslSocket: SSLSocket): String? { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Callback.kt
* timeout. Because networks can fail during an exchange, it is possible that the remote server * accepted the request before the failure. */ fun onFailure( call: Call, e: IOException, ) /** * Called when the HTTP response was successfully returned by the remote server. The callback may * proceed to read the response body with [Response.body]. The response is still live until its
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.6K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
val sslDebug: Boolean by option(help = "Output SSL Debug").flag() val url: String? by argument(name = "url", help = "Remote resource URL") var client: Call.Factory? = null override fun run() { LoggingUtil.configureLogging(debug = verbose, showHttp2Frames = showHttp2Frames, sslDebug = sslDebug) commonRun() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1)