- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for Async (0.12 sec)
-
README.md
```java import org.codelibs.curl.Curl; Curl.post("https://api.example.com/items") .body("{\"name\":\"item1\"}") .header("Content-Type", "application/json") .execute( response -> System.out.println("Async status: " + response.getHttpStatusCode()), error -> error.printStackTrace()); ``` ## API Overview - `org.codelibs.curl.Curl`: entry point for HTTP methods (GET, POST, PUT, DELETE, HEAD, OPTIONS, CONNECT, TRACE).
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Thu Nov 20 13:34:13 UTC 2025 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/login/FessLoginAssist.java
import org.codelibs.fess.sso.SsoAuthenticator; import org.codelibs.fess.util.ComponentUtil; import org.dbflute.optional.OptionalEntity; import org.dbflute.optional.OptionalThing; import org.lastaflute.core.magic.async.AsyncManager; import org.lastaflute.core.time.TimeManager; import org.lastaflute.web.login.LoginHandlingResource; import org.lastaflute.web.login.PrimaryLoginManager; import org.lastaflute.web.login.TypicalLoginAssist;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRpcClient.java
} } else { log.warn("Async notify failed: {}", message.getErrorMessage()); } return null; } catch (Exception e) { throw new IOException("Witness async notify RPC failed", e); } } /** * Generates a registration ID from context handle and share name.Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 12.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/CommonServerMessageBlockResponseTest.java
// Create a concrete implementation for comprehensive testing CommonServerMessageBlockResponse concreteResponse = new CommonServerMessageBlockResponse() { private boolean async = false; private CommonServerMessageBlockResponse next; private boolean received = false; private boolean error = false; private boolean verifyFailed = false;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/CommonServerMessageBlockResponse.java
* * @author mbechler */ public interface CommonServerMessageBlockResponse extends CommonServerMessageBlock, Response { /** * Checks if this is an asynchronous response. * * @return is an async response */ boolean isAsync(); /** * * @return the next response */ @Override CommonServerMessageBlockResponse getNextResponse(); /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
import org.codelibs.fess.util.RenderDataUtil; import org.codelibs.fess.util.ResourceUtil; import org.codelibs.fess.util.SearchEngineUtil; import org.dbflute.bhv.readable.EntityRowHandler; import org.lastaflute.core.magic.async.AsyncManager; import org.lastaflute.web.Execute; import org.lastaflute.web.response.ActionResponse; import org.lastaflute.web.response.HtmlResponse; import org.lastaflute.web.response.StreamResponse;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 02:07:40 UTC 2025 - 32.1K bytes - Viewed (0) -
CLAUDE.md
2. **Factory Pattern**: `Curl` class provides static factory methods for each HTTP method 3. **Resource Management**: `CurlResponse` implements `Closeable` for try-with-resources 4. **Async Support**: Both synchronous (`executeSync()`) and asynchronous (`execute()`) execution modes ## Technical Details - **Java Version**: 17+ - **Dependencies**: - Apache Commons IO 2.19.0 (runtime)
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Mon Nov 24 03:10:07 UTC 2025 - 3.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/RequestTest.java
} } /** * Test implementation of CommonServerMessageBlockResponse */ private static class TestResponse implements CommonServerMessageBlockResponse { private boolean async = false; private CommonServerMessageBlockResponse nextResponse; private boolean received = false; private int errorCode = 0; private long mid = 0; private Long expiration = null;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java
* * @param config * The configuration to use * @param mid * The message ID of the request to cancel * @param asyncId * The async ID for asynchronous operations (0 for synchronous) */ public Smb2CancelRequest(final Configuration config, final long mid, final long asyncId) { super(config, SMB2_CANCEL); setMid(mid);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java
assertEquals('a', stream.read()); assertEquals(-1, stream.read()); // EOF } // File should be deleted after close // Note: FileUtil.deleteInBackground() is async, so we can't reliably test this } public void test_available() throws Exception { // Create a temporary file with test data File tempFile = File.createTempFile("test-", ".tmp");
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 7.2K bytes - Viewed (0)