- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for stacked (0.17 sec)
-
mockwebserver-junit5/src/main/kotlin/mockwebserver3/junit5/internal/MockWebServerExtension.kt
private val servers = mutableMapOf<String, MockWebServer>() private var started = false fun server(name: String): MockWebServer { return servers.getOrPut(name) { MockWebServer().also { if (started) it.start() } } } fun startAll() { started = true for (server in servers.values) { server.start() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 11 12:12:36 GMT 2024 - 4.1K bytes - Viewed (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/internal/ExtensionLifecycleTest.kt
fun beforeEach(server: MockWebServer) { instanceServer = server assertThat(instanceServer).isNotSameInstanceAs(staticServer) assertThat(instanceServer).isSameInstanceAs(server) assertThat(server.started).isTrue() server.enqueue(MockResponse()) } @AfterEach fun afterEach(server: MockWebServer) { assertThat(server).isSameInstanceAs(instanceServer) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 11 12:12:36 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) /** * Notification that the receiving connection flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */
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) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* server may not have had time to close the socket. The socket will be closed at an indeterminate * point before or during the second request. It may be closed after client has started sending the * request body. If a request body is not retryable then the client may fail the request, making * client behavior non-deterministic. Add delays in the client to improve the chances that the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* * The target execution time is implemented on a best-effort basis. If another task in this queue * is running when that time is reached, that task is allowed to complete before this task is * started. Similarly the task will be delayed if the host lacks compute resources. * * @throws RejectedExecutionException if the queue is shut down and the task is not cancelable. */ fun schedule( task: Task,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* Any IO - writing to files or network should be done asynchronously. */ @ExperimentalOkHttpApi abstract class ConnectionListener { /** * Invoked as soon as a call causes a connection to be started. */ open fun connectStart( route: Route, call: Call, ) {} /** * Invoked when a connection fails to be established. */ open fun connectFailed( route: Route,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Handshake.kt
* handshakes. */ class Handshake internal constructor( /** * Returns the TLS version used for this connection. This value wasn't tracked prior to OkHttp * 3.0. For responses cached by preceding versions this returns [TlsVersion.SSL_3_0]. */ @get:JvmName("tlsVersion") val tlsVersion: TlsVersion, /** Returns the cipher suite used for the connection. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.8K bytes - Viewed (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/internal/ExtensionMultipleInstancesTest.kt
) { defaultInstancePort = defaultInstance.port instanceAPort = instanceA.port instanceBPort = instanceB.port assertThat(defaultInstance.started).isTrue() assertThat(instanceA.started).isTrue() assertThat(instanceB.started).isTrue() assertThat(defaultInstancePort).isNotEqualTo(instanceAPort) assertThat(defaultInstancePort).isNotEqualTo(instanceBPort) } @AfterEach fun tearDown(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 2.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
get() = delegate.protocols set(value) { delegate.protocols = value } init { delegate.dispatcher = dispatcher.wrap() } private var started: Boolean = false @Synchronized override fun before() { if (started) return try { start() } catch (e: IOException) { throw RuntimeException(e) } } @JvmName("-deprecated_port") @Deprecated(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 5.9K bytes - Viewed (0)