return fileInputStream.available();
    }

    /**
     * Closes this input stream and releases any system resources associated with the stream.
     * @throws IOException if an I/O error occurs.
     */
    @Override
    public void close() throws IOException {
        try {
            fileInputStream.close();
        } finally {
            FileUtil.deleteInBackground(tempFile);
        }

            } catch (InterruptedException ignore) {}
            deferred.reject(new Exception());
        });
        th.start();

        final CountDownLatch latch = new CountDownLatch(1);
        deferred.promise().error(error -> latch.countDown());
        assertTrue(latch.await(10, TimeUnit.SECONDS));
    }

    @Test
    public void test_doneAfterReject() throws Exception {

        CrawlerSystemException exception1 = new CrawlerSystemException(exceptionCause);
        assertSame(exceptionCause, exception1.getCause());

        // With Error cause
        Error errorCause = new Error("Error cause");
        CrawlerSystemException exception2 = new CrawlerSystemException(errorCause);
        assertSame(errorCause, exception2.getCause());

        // With RuntimeException cause

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.exception;

/**
 * This exception is thrown when an error occurs during OpenSearch access.
 *
 * @author shinsuke
 *
 */
public class OpenSearchAccessException extends CrawlerSystemException {

    private static final long serialVersionUID = 1L;

    /**

     */
    default int getMaxReadingNum() {
        return 10;
    }

    /**
     * Initializes the converter.
     *
     * @throws IOException if an I/O error occurs during initialization.
     */
    void init() throws IOException;

    /**
     * Converts the given text into a list of readings based on the specified field and languages.
     *

     *
     * @throws IOException if an I/O error occurs (not thrown in this implementation)
     */
    @Override
    public void close() throws IOException {
        // inputStream.close();
    }

    /**
     * Returns the number of bytes that can be read from this input stream without blocking.
     *
     * @return the number of bytes available
     * @throws IOException if an I/O error occurs
     */
    @Override

    }

    /**
     * Processes system error log events.
     *
     * @param objs the log objects (should contain a Throwable)
     */
    protected void processSystemError(final Object... objs) {
        final Throwable t = (Throwable) objs[0];
        if (logger.isErrorEnabled()) {
            logger.error("System Error.", t);
        }
    }

    /**

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.exception;

/**
 * RobotsTxtException is an exception class that represents an error related to robots.txt processing during web crawling.
 * It extends CrawlerSystemException and provides constructors to create instances with a message and/or a cause.
 *
 */

    FINISHED_THREAD,
    /** Indicates no response processor is available. */
    NO_RESPONSE_PROCESSOR,
    /** Indicates no rule is available for processing. */
    NO_RULE,
    /** Indicates a system error occurred. */
    SYSTEM_ERROR

     *
     * @param responseData the response data containing the response body
     * @return a temporary file containing the response body
     * @throws CrawlingAccessException if an error occurs while reading the response body
     */
    public static File createResponseBodyFile(final ResponseData responseData) {
        File tempFile = null;
        FileOutputStream fos = null;