Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for asynchronously (0.64 sec)

  1. src/main/java/jcifs/internal/CommonServerMessageBlockRequest.java

     * asynchronous handling, message chaining, cancellation, and timeout management.
     *
     * @author mbechler
     */
    public interface CommonServerMessageBlockRequest extends CommonServerMessageBlock, Request {
    
        /**
         * Checks if the request will be handled asynchronously.
         *
         * @return request was handled asynchronously
         */
        boolean isResponseAsync();
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/util/InputStreamThread.java

    import org.apache.logging.log4j.Logger;
    
    /**
     * A thread that reads from an input stream line by line and maintains a buffer of recent lines.
     * This class provides functionality to read input stream data asynchronously,
     * optionally process each line with a callback function, and maintain a circular buffer
     * of recent lines for retrieval.
     */
    public class InputStreamThread extends Thread {
        /** Logger instance for this class */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java

            TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile);
            stream.read(); // Read some data
            stream.close();
    
            // Note: FileUtil.deleteInBackground() performs deletion asynchronously,
            // so we cannot reliably check if file is deleted immediately
            // This test just verifies that close() completes without error
        }
    
        public void test_emptyFile() throws Exception {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  4. README.md

    - Support for query parameters, headers, body (String or stream), compression, SSL configuration, proxies, and timeouts
    - Automatic in-memory or on-disk caching of request/response bodies
    - Synchronous and asynchronous (callback) execution
    - Minimal dependencies (only Apache Commons IO)
    
    ## Installation
    
    ### Maven
    
    Add the dependency to your `pom.xml` (replace `x.y.z` with the latest version):
    
    ```xml
    <dependency>
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/CommonServerMessageBlockResponse.java

     * Extends the common SMB message block with response-specific functionality including
     * asynchronous response handling and response chaining capabilities.
     *
     * @author mbechler
     */
    public interface CommonServerMessageBlockResponse extends CommonServerMessageBlock, Response {
    
        /**
         * Checks if this is an asynchronous response.
         *
         * @return is an async response
         */
        boolean isAsync();
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/ServerMessageBlock2Response.java

            this.expiration = exp;
        }
    
        /**
         * Checks whether the asynchronous interim response has been handled.
         *
         * @return whether the interim response has been handled
         */
        public boolean isAsyncHandled() {
            return this.asyncHandled;
        }
    
        /**
         * Sets whether the asynchronous interim response has been handled.
         *
         * @param asyncHandled
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/base/login/EntraIdCredential.java

                this.roles = roles;
            }
    
            /**
             * Resets permissions to force recalculation on next getPermissions() call.
             * This is called after asynchronous parent group lookup completes.
             */
            public void resetPermissions() {
                this.permissions = null;
            }
        }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMailDeliveryDepartmentCreator.java

                }
            };
        }
    
        // ===================================================================================
        //                                                                        Asynchronous
        //                                                                        ============
        protected void async(final AsyncManager asyncManager, final Runnable runnable) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7K bytes
    - Viewed (0)
  9. CLAUDE.md

    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)
      - JUnit 4.13.2 (test)
    - **Module Name**: `org.codelibs.curl4j`
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Mon Nov 24 03:10:07 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. 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);
            setAsyncId(asyncId);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top