- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 422 for clientY (0.67 sec)
-
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* * @return the thread pool */ @Override public ThreadPool threadPool() { return client.threadPool(); } /** * Gets the admin client for cluster and index administration. * * @return the admin client */ @Override public AdminClient admin() { return client.admin(); } /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
fun build(): DnsOverHttps { val client = this.client ?: throw NullPointerException("client not set") return DnsOverHttps( client.newBuilder().dns(buildBootstrapClient(this)).build(), checkNotNull(url) { "url not set" }, includeIPv6, post, resolvePrivateAddresses, resolvePublicAddresses, ) } fun client(client: OkHttpClient) = apply {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/exentity/CrawlingConfig.java
import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.CrawlerClientFactory; import org.codelibs.fess.crawler.client.ftp.FtpClient; import org.codelibs.fess.crawler.client.http.HcHttpClient; import org.codelibs.fess.crawler.client.smb.SmbClient; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.util.ComponentUtil;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 5.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Handshake.kt
import java.security.cert.X509Certificate import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession import okhttp3.internal.toImmutableList /** * A record of a TLS handshake. For HTTPS clients, the client is *local* and the remote server is * its *peer*. * * This value object describes a completed handshake. Use [ConnectionSpec] to set policy for new * handshakes. */ class Handshake internal constructor(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Apr 05 09:48:10 UTC 2025 - 6.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
private void run() { OkHttpClient client = new OkHttpClient.Builder() .readTimeout(0, TimeUnit.MILLISECONDS) .build(); Request request = new Request.Builder() .url("ws://echo.websocket.org") .build(); client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Apr 04 11:40:21 UTC 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
client.processNextFrame() // Read server close, send client close, close connection. assertThat(client.closed).isFalse() client.listener.assertClosing(1000, "Hello!") client.webSocket!!.finishReader() client.webSocket!!.close(1000, "Hello!") server.processNextFrame() server.listener.assertClosing(1000, "Hello!") server.webSocket!!.finishReader() client.listener.assertClosed(1000, "Hello!")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.7K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/LetsEncryptTest.java
* * Read https://community.letsencrypt.org/t/mobile-client-workarounds-for-isrg-issue/137807 * for background. */ @RunWith(AndroidJUnit4.class) public class LetsEncryptTest { @Test public void getFailsWithoutAdditionalCert() throws IOException { OkHttpClient client = new OkHttpClient(); boolean androidMorEarlier = Build.VERSION.SDK_INT <= 23; try { sendRequest(client, "https://valid-isrgrootx1.letsencrypt.org/robots.txt");
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Nov 17 07:40:31 UTC 2020 - 6.1K bytes - Viewed (0) -
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) -
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) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DohProviders.kt
.build() @JvmStatic fun providers( client: OkHttpClient, http2Only: Boolean, workingOnly: Boolean, getOnly: Boolean, ): List<DnsOverHttps> = buildList { add(buildGoogle(client)) if (!getOnly) { add(buildGooglePost(client)) } add(buildCloudflare(client)) add(buildCloudflareIp(client)) if (!getOnly) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.8K bytes - Viewed (0)