- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for deterministic (0.2 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
import kotlin.concurrent.withLock import okhttp3.OkHttpClient import okhttp3.TestUtil.threadFactory /** * Runs a [TaskRunner] in a controlled environment so that everything is sequential and * deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* 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 * server has closed the socket before follow up requests are made. */ @ExperimentalOkHttpApi sealed interface SocketPolicy { /**
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-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
* * The returned client installs a default event listener that gathers debug information. This will * be logged if the test fails. * * This client is also configured to be slightly more deterministic, returning a single IP * address for all hosts, regardless of the actual number of IP addresses reported by DNS. */ fun newClient(): OkHttpClient { var client = testClient if (client == null) {
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/test/java/okhttp3/URLConnectionTest.kt
// number 0. Since the client may have attempted to reuse the broken connection just before // creating a fresh connection, the server may have recorded 2 requests at this point. The order // of recording is non-deterministic. val requestAfter = server.takeRequest() assertThat( requestAfter.sequenceNumber == 0 || server.requestCount == 3 && server.takeRequest().sequenceNumber == 0, ).isTrue() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
/** * Streaming decoder of data encoded following Abstract Syntax Notation One (ASN.1). There are * multiple variants of ASN.1, including: * * * DER: Distinguished Encoding Rules. This further constrains ASN.1 for deterministic encoding. * * BER: Basic Encoding Rules. * * This class was implemented according to the [X.690 spec][[x690]], and under the advice of * [Lets Encrypt's ASN.1 and DER][asn1_and_der] guide. *
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) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
OkHttpClient.Builder() .trustMockServer() .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor())) .build() executor = newVirtualThreadPerTaskExecutor() // Capture non-deterministic but probable sysout warnings of pinned threads // https://docs.oracle.com/en/java/javase/21/core/virtual-threads.html System.setOut(PrintStream(capturedOut)) } @AfterEach fun checkForPinning() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 11:15:46 GMT 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
) : QueueDispatcher() { private var responseIndex = 0 @Synchronized override fun dispatch(request: RecordedRequest): MockResponse { // This guarantees a deterministic sequence when handling the canceled request: // 1. Server reads request and dequeues first response // 2. Client cancels request // 3. Server tries to send response on the canceled stream
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0)