- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for on_connect (0.07 seconds)
-
src/test/java/org/codelibs/curl/CurlRequestTest.java
// Setting onConnect to null should work request.onConnect(null); assertNotNull(request); } @Test public void testMultipleOnConnectCalls() { CurlRequest request = new CurlRequest(Method.GET, "https://example.com"); // Multiple onConnect calls should work (last one wins) request.onConnect((req, conn) -> conn.setConnectTimeout(1000));Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 24.7K bytes - Click Count (0) -
src/test/java/org/codelibs/curl/io/IOIntegrationTest.java
mockHolder[0] = mock; return mock; }); req.timeout(3000, 5000); // onConnect runs AFTER timeout, so it can override req.onConnect((r, conn) -> { conn.setReadTimeout(9999); onConnectReadTimeout.set(conn.getReadTimeout()); }); // ## Act ##
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 12:00:34 GMT 2026 - 44.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt
} OverrideParam.ConnectTimeout -> { client = client .newBuilder() .socketFactory( DelayingSocketFactory(onConnect = { timeout -> if (timeout == 10) { throw IOException() } }), ).build()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 11 02:37:00 GMT 2026 - 28.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java
} else if (entry.getValue().length == 1) { curlRequest.param(entry.getKey(), entry.getValue()[0]); } }); try (final CurlResponse curlResponse = curlRequest.onConnect((req, con) -> { con.setDoOutput(true); if (httpMethod != Method.GET && request.getContentLength() > 2) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:40 GMT 2026 - 13.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
} final ObjectMapper mapper = new ObjectMapper(); final AtomicBoolean resetJobs = new AtomicBoolean(false); try (CurlResponse response = ComponentUtil.getCurlHelper().post("/_bulk").onConnect((req, con) -> { con.setDoOutput(true); try (final BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(tempFile)));Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Nov 24 02:07:40 GMT 2025 - 32.1K bytes - Click Count (0) -
src/main/java/org/codelibs/curl/CurlRequest.java
/** * Sets the connection builder for customizing the connection. * * @param connectionBuilder the connection builder * @return this CurlRequest instance */ public CurlRequest onConnect(final BiConsumer<CurlRequest, HttpURLConnection> connectionBuilder) { this.connectionBuilder = connectionBuilder; return this; } /** * Adds a request parameter. *Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 19.7K bytes - Click Count (0)