- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 1,321 for clientY (0.03 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
client.newWebSocket(newRequest("http://a/2"), webSocketListener) client.newWebSocket(newRequest("http://a/3"), webSocketListener) executor.assertJobs("http://a/1", "http://a/2", "http://a/3") } @Test fun increasingMaxRequestsPromotesJobsImmediately() { dispatcher.maxRequests = 2 client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://b/1")).enqueue(callback)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java
* Called when a request starts. * * @param client the fault-tolerant client * @param request the request data */ void onRequestStart(FaultTolerantClient client, RequestData request); /** * Called before each request attempt. * * @param client the fault-tolerant client * @param request the request data
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 7.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
.message("Intercepted!") .body("abc".toResponseBody("text/plain; charset=utf-8".toMediaType())) .build() client = client .newBuilder() .addInterceptor(Interceptor { chain: Interceptor.Chain? -> interceptorResponse }) .build() val response = client.newCall(request).execute() assertThat(response).isSameInstanceAs(interceptorResponse) } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 28.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/WitnessClientTest.java
// Create a test witness client that uses our mock RPC client TestWitnessClient client = new TestWitnessClient(witnessServer, mockContext, mockRpc); TestNotificationListener listener = new TestNotificationListener(); CompletableFuture<WitnessRegistration> future = client.registerForNotifications("\\\\server\\share", serverAddress, listener);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 9.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
val response = client.newCall(request).execute() assertThat(response.body.string()).isEqualTo("b") assertThat(server.takeRequest().exchangeIndex).isEqualTo(0) assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) } @Test fun connectionsNotReusedWithRedirectIfDiscardingResponseIsSlow() { client = client .newBuilder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 12.2K bytes - Viewed (1) -
docs/sts/README.md
# MinIO STS Quickstart Guide [](https://slack.min.io) The MinIO Security Token Service (STS) is an endpoint service that enables clients to request temporary credentials for MinIO resources. Temporary credentials work almost identically to default admin credentials, with some differences:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
private fun enableProtocol(protocol: Protocol) { enableTls() client = client .newBuilder() .protocols(listOf(protocol, Protocol.HTTP_1_1)) .build() server1.protocols = client.protocols server2.protocols = client.protocols } private fun enableTls() { client = client .newBuilder() .sslSocketFactory(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 11.7K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
val request = Request.Builder().url(server.url("/")).build() client.newCall(request).execute().use { response -> assertEquals(200, response.code) } client.connectionPool.evictAll() assertEquals(0, client.connectionPool.connectionCount()) client.newCall(request).execute().use { response -> assertEquals(200, response.code) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 14:12:28 UTC 2025 - 29K bytes - Viewed (0) -
README.md
```properties # Connection settings jcifs.smb.client.connTimeout=35000 jcifs.smb.client.soTimeout=180000 jcifs.smb.client.responseTimeout=30000 # Authentication jcifs.smb.client.domain=WORKGROUP jcifs.smb.client.username=guest jcifs.smb.client.password= # Protocol versions (SMB1 to SMB 3.1.1) jcifs.smb.client.minVersion=SMB1 jcifs.smb.client.maxVersion=SMB311 # Security
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 09:24:52 UTC 2025 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/normalizer/AnalyzerNormalizer.java
/** * Constructs an AnalyzerNormalizer with the specified client and settings. * * @param client the OpenSearch client * @param settings the settings for suggestions */ public AnalyzerNormalizer(final Client client, final SuggestSettings settings) { this.client = client; this.settings = settings; analyzerSettings = settings.analyzer(); }
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 4K bytes - Viewed (0)